java Flink作业流在使用Flink联合流进行聚合操作后停止

Question

我在办理工会手续时遇到了一些麻烦。数据流似乎在还原操作后停止。 下面是完整的流程

重试消息（卡夫卡重试主题）+正常消息->；车窗钥匙开关->；还原->；进程（用于侧输出以收集未通过验证条件的消息，然后将其放入重试主题）

我对数据管道进行了一些调试，我非常确定union操作的引入导致了这个问题。如果我删除union操作符，一切正常

问题是我在日志中没有看到任何错误消息。似乎聚合的消息丢失了，因为我可以看到reduce函数调试点被挂起