这是上周出现的问题了，简单做个记录。 有一个按平台类型实时统计用户活跃的程序，代码框架如下。 就是水印→开窗→聚合→输出的经典套路。程序正常运行一段时间之后，连续报检查点超时...
发简信
IP属地：四川
-
用两阶段聚合法解决Flink keyBy()算子倾斜 -
本博客所有内容均适用知识共享-署名-相同方式共享（CC-BY-SA）4.0协议。
-
Flink之用户代码生成调度层图结构在Flink中，由用户代码生成调度层图结构，可以分成3步走：通过Stream API编写的用户代码 -> StreamGraph -> JobGraph -> Executi...
-
-
