我有两个原始流，我正在加入这些流，然后我要计算已加入的事件总数是多少，尚未加入的事件有多少。我通过使用joinedEventDataStream如下所示的地图来做到这一点

joinedEventDataStream.map(new RichMapFunction<JoinedEvent, Object>() {

            @Override
            public Object map(JoinedEvent joinedEvent) throws Exception {

                number_of_joined_events += 1;

                return null;
            }
        });

问题1： 这是计算流中事件数量的适当方法吗？

问题2： 我注意到一种有线行为，有些人可能不相信。问题是，当我在IntelliJ
IDE中运行Flink程序时，它显示了的正确值，number_of_joined_events但是0当我将该程序提交为时jar。因此，我获得了number_of_joined_events将程序作为jar文件运行而不是实际计数时的初始值。为什么仅在jar提交文件而不在IDE中发生这种情况？