您的方法无效。通过JAR文件执行程序时,您会注意到行为。
我不知道该如何
number_of_joined_events定义,但是我假设它在您的程序中是一个静态变量。当您在IDE中运行该程序时,它将在单个JVM中运行。因此,所有运算符都可以访问静态变量。当您将JAR文件提交到远程进程时,程序将在其他JVM(可能是多个JVM)中执行,并且客户端进程中的静态变量永远不会更新。
您可以使用Flink的指标或的
ReduceFunction总和
1来计算已处理记录的数量。

您的方法无效。通过JAR文件执行程序时,您会注意到行为。
我不知道该如何
number_of_joined_events定义,但是我假设它在您的程序中是一个静态变量。当您在IDE中运行该程序时,它将在单个JVM中运行。因此,所有运算符都可以访问静态变量。当您将JAR文件提交到远程进程时,程序将在其他JVM(可能是多个JVM)中执行,并且客户端进程中的静态变量永远不会更新。
您可以使用Flink的指标或的
ReduceFunction总和
1来计算已处理记录的数量。