title: flink events are coming to jobmanager but not to taskmanager in cluster
body: <p>I am trying to run flink application on cluster. Application deployed successfully and I can see jobmanger and taskmanager are running and resource registration is done successfully.</p>
  <p>Application need dummy event and it is working fine and sql query is also returning the result (by taskmanager).</p>
  <p>Problem: Application receiving events from message hub but these messages are with jobmanager only and to coming to taskmanager for execution in cluster (standalone). But it works fine with intelliJ.</p>
  <p>I understand if it would have kafka then addSource(new FlinkKafkaConsumer()) work but for me I have to register callback and then message comes onEvent.</p>
  <p>is there any mechanism which can help to send events to taskmanager from jobmanager in cluster?</p>