Flinkcdc同步mysql数据到Doris-streamload出错跳过数据问题
问题描述Flinkcdc实时同步mysql数据到doris,原始修改表结构需要停任务,自己手工同步修改更新表结构,再重启任务,比较麻烦,基于此自定义Dorissink,刚开始没implements CheckpointedFunction类,会出现,这个checkpoint失败的时候,直接跳过这个checkpoint的数据,这样就会导致漏数据。 引起checkpoint失败的原因举例:Doris表