我有一个 flink 作业 (1.14)，每隔几个小时计算一次窗口聚合。我发现所有事件都有相同的窗口范围，因此数百万个聚合结果都同时完成，即窗口结束。
聚合后，我应该立即将结果下沉到外部数据库。而且这种尖峰模式无论对 flink 作业本身还是数据库来说显然都是不健康的。
谢谢！！
我试图：