有大佬们遇到用HoodieFlinkStreamer时,会生成很多rollback文件么, 我在排查[阿里云实时计算 Flink版]

有大佬们遇到用HoodieFlinkStreamer时,会生成很多rollback文件么, 我在排查过程中发现: 在拉起整个任务的时候,会一直调用AbstractStreamWriteFunction的initializeState方法,我理解initializeState应该只是会在算子的初始化或者异常恢复的时候调用吧(目前没发现啥异常), initializeState调用时会异步发消息生成deltacommit和rollback文件

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====