canal 指定位点启动异常

k5hmc34c  于 4个月前  发布在  其他
关注(0)|答案(3)|浏览(109)
  • I have searched the issues of this repository and believe that this is not a duplicate.
  • I have checked the FAQ of this repository and believe that this is not a duplicate.

environment

  • canal version 5.7.25-log
  • mysql version 1.1.6

Issue Description

Mysql 库很久没有数据变更,删除zk游标中的数据,canal.instance.master.timestamp设置了一个未来时间。

因为这里的
CanalEntry.Entry entry = parseAndProfilingIfNecessary(event, true);
解析出的都为NULL,导致logPosition.setPostion 没有赋值。
针对这种情况,将日志最新位点赋予logPosition比较合理

Steps to reproduce

Expected behaviour

报异常
[Didn't find the corresponding binlog files from mysql-bin.006441 to mysql-bin.006520]

Actual behaviour

正常启动

If there is an exception, please attach the exception trace:

Just put your stack trace here!
blmhpbnm

blmhpbnm1#


binlog文件中只有这两种类型的日志,parser方法返回的均为null

rxztt3cl

rxztt3cl2#

没有任何DML变更?

dldeef67

dldeef673#

是的,一个测试库很久没有操作过了

相关问题