Jobmanager为程序中的每一个operator发起checkpoint已经完成的回调。method,并使sink呈现Exactly-Once语义。checkpoint中。在从checkpoint恢复的时候,它会优先提交一个commit。可以构建端到端的Exactly-Once程序。TwoPhaseCommitSinkFunction的producer。其核心设计理念与Spark有很大的不同。下面是我在Chrome上的代码。