我编写了一个 Flink 程序，用于从简单的 kafka 流计算每个键控窗口的事件数。我工作出色、快速且准确。当源停止时，我希望每个窗口的计算结果为 0，但没有发送结果。该函数只是不执行。我认为这是因为 Flink 的惰性操作行为。
有什么推荐吗？
最佳答案
我也遇到过同样的情况。用另一个进程填补数据库中的漏洞是一个解决方案。
但是，我发现将主流与自定义期刊源结合起来更容易，该源会发出虚拟数据，其唯一作用是触发窗口创建。执行此操作时，您必须确保在计算中忽略虚拟对象。
Here is how to code a periodical source (但是您可能不需要 RichParallelSourceFunction，SourceFunction 就足够了)
关于apache-flink - 如何在Flink流中的空窗口上执行函数？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/34326408/