streamsets offset保存流程
2021-03-23 11:17:20 1 举报streamsets offset保存流程
作者其他创作
大纲/内容
吧当前offset文件移动到offset-old文件
读取offset文件，得到offset
从上一次offset开始运行下一批次任务
将要提交的offset写入临时文件tmp
将临时文件移动为正式offset文件
是否有offset文件
删除offset-old文件
从未完成的临时文件old，tmp文件恢复offset文件，得到offset
无
当前批次运行完成，得到完成后的新offset
启动管道
有
保存新的offset
保存offset
0 条评论
下一页
