我编写了一个flink程序，从一个简单的kafka流计算每个键控窗口的事件数。我的工作很好，快速和准确。当源停止时，我想 0 作为每个窗口的计算结果，但不发送结果。函数就是不执行。我想这是因为flink的懒惰操作行为。有什么建议吗？
0
czq61nw11#
我也遇到了同样的情况。用另一个进程填补数据库中的漏洞是一个解决方案。然而，我发现将主流与一个定制的周期性源结合起来更容易，这个源会发出假人，假人的唯一角色是触发windows创建。在执行此操作时，必须确保在计算中忽略假人。下面是如何编写周期性源代码（但是您可能不需要richpallelsourcefunction，sourcefunction就足够了）
1条答案
按热度按时间czq61nw11#
我也遇到了同样的情况。用另一个进程填补数据库中的漏洞是一个解决方案。
然而，我发现将主流与一个定制的周期性源结合起来更容易，这个源会发出假人，假人的唯一角色是触发windows创建。在执行此操作时，必须确保在计算中忽略假人。
下面是如何编写周期性源代码（但是您可能不需要richpallelsourcefunction，sourcefunction就足够了）