我正在尝试在集群上运行flink应用程序。应用程序部署成功，我可以看到jobmanager和taskmanager正在运行，资源注册也成功完成。
应用程序需要伪事件，它运行良好，sql查询也返回结果(由taskmanager(。
问题：应用程序从消息中心接收事件，但这些消息仅与jobmanager一起发送，并发送到taskmanager以在集群中执行(独立(。但它在intelliJ上运行良好。
我知道如果它有kafka，那么addSource(new FlinkKafkaConsumer(((就可以工作了，但对我来说，我必须注册回调，然后消息就会出现在Event上。
是否有任何机制可以帮助将事件从集群中的jobmanager发送到taskmanager？
根本不应该在JobManager上处理事件。这种行为的一个可能原因是您使用本地执行器启动应用程序。你能仔细检查一下你是如何创建流环境的吗？