我写了一个Flink程序，它从一个简单的kafka流中计算每个键控窗口的事件数 . 我工作得很好，快速而准确 . 当源停止时，我希望 0 作为每个窗口的计算结果，但没有结果发送 . 该函数不执行 . 我认为这是因为Flink的懒惰操作行为 .
0
有什么建议？
我遇到了同样的情况 . 使用其他流程填充数据库中的漏洞是一种解决方案 .
但是，我发现将主流与自定义期刊源联合起来更容易，这些源会发出虚拟对象，其唯一的作用是触发窗口创建 . 执行此操作时，您必须确保在计算中忽略虚拟对象 .
Here is how to code a periodical source（但是你可能不需要RichParallelSourceFunction，SourceFunction就足够了）
1 回答
我遇到了同样的情况 . 使用其他流程填充数据库中的漏洞是一种解决方案 .
但是，我发现将主流与自定义期刊源联合起来更容易，这些源会发出虚拟对象，其唯一的作用是触发窗口创建 . 执行此操作时，您必须确保在计算中忽略虚拟对象 .
Here is how to code a periodical source（但是你可能不需要RichParallelSourceFunction，SourceFunction就足够了）