问如何在Flink streaming中对空窗口执行函数？
EN

Stack Overflow用户

提问于 2015-12-17 12:03:17

回答 1查看 894关注 0票数 1

我写了一个Flink程序，从一个简单的kafka流计算每个键控窗口的事件数。当源停止时，我希望将0作为每个窗口的计算结果，但没有发送任何结果。我认为这是因为Flink的懒惰操作行为。

有什么建议吗？

发布于 2018-12-01 19:45:20

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

然而，我发现将你的主流和一个定制的周期性源结合起来更容易，它会发出虚拟对象，其唯一的作用就是触发窗口创建。在执行此操作时，必须确保在计算中忽略虚拟对象。

Here is how to code a periodical source (但是您可能不需要RichParallelSourceFunction，一个SourceFunction就足够了)

票数 1

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/34326408

复制

相似问题

问如何在Flink streaming中对空窗口执行函数？EN