hankerlin

Closer线程安全问题

1

```java public class ProtostuffCodecUtil implements MessageCodecUtil { private static Closer closer = Closer.create();//存在线程安全问题 ...... } ```

客户端对不同地址的服务器进行RPC调用问题

2

在阅读作者源码的时候，发现了这样一个问题： 在单例RpcServerLoader中封装了messageSendHandler： public class RpcServerLoader { ... private MessageSendHandler messageSendHandler = null; ... } 而messageHandler一个的重要作用就是就是向RPC服务器发送信息： public class MessageSendProxy extends AbstractInvocationHandler { @Override public Object handleInvocation(Object proxy, Method method, Object[] args)...

public class MethodProxyAdvisor implements MethodInterceptor { ... boolean existFilter = ServiceFilterBinder.class.isAssignableFrom(serviceBean.getClass()); ... } 无论是否配置过滤器，都会返回true.

CDC日志(更新操作)实时写入clickhouse，存在数据错误

1

假如有以下链路： mysql-cdc(debezium-json) -> clickhouse debezium-json会将cdc变更日志中的更新操作，转化为2条操作(-Delete +Insert) 当这个事件流通过flink-clickhouse-connector实时写入clickhouse时，因为-Delete事件触发的删除操作是异步的，会导致执行顺序错乱，比如会先执行+Insert操作，再执行-Delete操作， 导致这种场景下会出现数据问题，表现在：当有更新操作时，最终体现在clickhouse会表现为删除操作。