如何在Flink streaming的空窗口上执行函数?


0

我编写了一个Flink程序,从一个简单的kafka流计算每个 key控窗口的事件数。我的 job 很好,快速和准确。当源停止时,我希望每个窗口的计算结果为0,但不发送结果。函数就是不执行。我想这是因为Flink的懒惰操作行为。

有什么建议吗?

1 答案


0

我也遇到了同样的情况。用另一个进程填补数据库中的漏洞是一个解决方案。

然而,我发现将主流与一个定制的周期性源结合起来更容易,这个源会发出假人,假人的唯一角色是触发windows创建。在执行此操作时,必须确保在计算中忽略假人。

下面是如何编写周期性源代码(但是您可能不需要richpallelsourcefunction,SourceFunction就足够了)


我来回答

写文章

提问题

面试题