flink-cdc icon indicating copy to clipboard operation
flink-cdc copied to clipboard

[Bug] tidb 从checkpoint 恢复后,不会消费任务失败时间产生的binlog数据

Open WenDing-Y opened this issue 2 years ago • 0 comments

Search before asking

  • [X] I searched in the issues and found nothing similar.

Flink version

1.14.3

Flink CDC version

3.0.0

Database and its version

5.7.25-TiDB-v5.2.2

Minimal reproduce step

1.set restart config // 设置从最近的检查点恢复 env.setRestartStrategy(RestartStrategies.fixedDelayRestart( 3, // 最大尝试重启次数 Time.seconds(60) // 重启的时间间隔 )); 2.kill taskmanager 3.update db data 4.start taskmanager 5.view data print (do data print)

What did you expect to see?

print data change between in task faild

What did you see instead?

fix bug

Anything else?

No response

Are you willing to submit a PR?

  • [X] I'm willing to submit a PR!

WenDing-Y avatar Jan 30 '24 03:01 WenDing-Y