40049aae4762

这是上周出现的问题了，简单做个记录。 有一个按平台类型实时统计用户活跃的程序，代码框架如下。 就是水印→开窗→聚合→输出的经典套路。程序正常运行一段时间之后，连续报检查点超时...

40049aae4762

在Flink中，由用户代码生成调度层图结构，可以分成3步走：通过Stream API编写的用户代码 -> StreamGraph -> JobGraph -> Executi...