Flink的checkpoint就是核心机制就是打旗子么。连续的时间流分开很多间隔。并行度，就是将间隔中的数据并行分开。现在有个问题就是两段式提交中的context如何定义实现