您好:
我确认我们两台mysql备库都开启了gtid选项,并且该问题我们进行了复现,复现步骤如下:
flink版本 1.14.5
flink-connector-mysql-cdc版本 2.2.0
mysql版本 5.6.0
1.准备两台备库,并且binlog文件名相差很远没有交集
2.采集第一台备库,等待数据正常写入后,停止该cdc采集任务,正常保存savepoint
3.修改采集mysql的配置信息为备库2,并且将flink任务正常从savepoint启动,就会出现上述反馈的问题
在 2024-01-19
Hi,
日志中有包含 GTID 的内容吗？
用 SHOW VARIABLES LIKE 'gtid_mode’; 确认下是否开启了GTID呢？
Best,
Jiabao
On 2024/01/19 09:36:38 wyk wrote:
>
>
>
>
>
>
>
>
>
> 抱歉,具体报错和代码如下:
>
>
> 报错部分:
> Caused by: java.lang.IllegalStateException: The connector is trying to read
> binlog starting at
>
抱歉,具体报错和代码如下:
报错部分:
Caused by: java.lang.IllegalStateException: The connector is trying to read
binlog starting at
Struct{version=1.5.4.Final,connector=mysql,name=mysql_binlog_source,ts_ms=1705645599953,db=,server_id=0,file=mysql_bin.007132,pos=729790304,row=0},
but this is no longer
