Hi 1 怎么对比得到“结果不一致”这个结论的呢? 2 是否有 window 算子呢,现在 checkpoint/savepoint 没有 记录 watermark 的。 3 你的 eventtime 是直接从 record 取的,还是计算出来的呢,如果是计算出来的话,重启是否影响计算逻辑得到的 eventtime 和 watermark 呢
Best, Congxian claylin <[email protected]> 于2020年6月22日周一 下午10:49写道: > hi all我这边有个去重作业,从savepoint启动后,发现作业运行结果和之前的结果不一致,作业采用的是event > time,不知道还有什么因素会导致状态不一样,求大佬支招
