Tag: flink cep

Apache Flink：如何计算DataStream中的事件总数

我有两个原始流，我正在加入这些流，然后我想计算已加入的事件总数和事件没有多少。 我是通过在joinedEventDataStream上使用map来joinedEventDataStream ，如下所示 joinedEventDataStream.map(new RichMapFunction() { @Override public Object map(JoinedEvent joinedEvent) throws Exception { number_of_joined_events += 1; return null; } }); 问题1：这是计算流中事件数量的适当方法吗？ 问题2：我注意到有线行为，有些人可能不相信。 问题是，当我在IntelliJ IDE中运行我的Flink程序时，它会向我显示number_of_joined_events正确值，但在我将此程序设置为jar时会显示0 。 所以当我将程序作为jar文件而不是实际计数运行时，我得到number_of_joined_events的初始值。 为什么只在jar文件提交而不在IDE中才会发生这种情况？