我在办理工会手续时遇到了一些麻烦。似乎数据流在还原操作之后停止了。这里是完整的流程
retry message（kafka retry topic）+普通消息->窗口keyby->reduction->进程（用于侧输出，以收集未通过验证标准的消息，然后将其放入retry topic）
我对数据管道进行了一些调试，我非常确定union操作的引入导致了这个问题。如果我去掉并集操作符，一切都会正常。
问题是我在日志中没有看到任何错误消息。似乎聚合的消息只是丢失了，因为我可以看到reduction函数debug point被挂起。