【 使用环境 】 测试环境
【 OB or 其他组件 】logproxy-client
【 使用版本 】1.0.6
【问题描述】logproxy-client notify里面报错
【复现路径】dbeaver里面建表后insert数据
【问题现象及影响】
能正常收到数据但是有报错日志：
[log-proxy-client-worker-1-thread-1] ERROR com.oceanbase.clogproxy.client.connection.ClientHandler - Failed to update checkpoint for log message: type:UPDATE
record_id:144115188075855872
db:sys.test
tb:t1
serverId:null
checkpoint:0@0
primary_value:
unique_keys:
Field name: v1
Field type: 15
Field length: 2
Field notNull: false
Field value: k2
Field name: v1
Field type: 15
Field length: 2
Field notNull: false
Field value: k2
Field name: i1
Field type: 8
Field length: 1
Field notNull: false
Field value: 4
Field name: i1
Field type: 8
Field length: 1
Field notNull: false
Field value: 5
java.lang.IllegalArgumentException: Update checkpoint with invalid value: 0
at com.oceanbase.clogproxy.client.connection.ClientStream.setCheckpointString(ClientStream.java:301)
at com.oceanbase.clogproxy.client.connection.ClientHandler.parseRecord(ClientHandler.java:346)
at com.oceanbase.clogproxy.client.connection.ClientHandler.parseDataNew(ClientHandler.java:292)
at com.oceanbase.clogproxy.client.connection.ClientHandler.handleRecord(ClientHandler.java:239)
at com.oceanbase.clogproxy.client.connection.ClientHandler.channelRead(ClientHandler.java:153)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:719)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:655)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:581)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at java.lang.Thread.run(Thread.java:748)
【附件】