Hi Colleagues,I have a 2-nodes Flink cluster.I send tuples from my laptop to
Kafka (its in the job-manager node).My Beam/FlinkRunner app is started from the
job-manager.I can see in logs that both nodes' job-managers are receiving
tuples from Kafka (unbounded KafkaIO).Underneath the statement where I print I
receive data from Kafka, some logic starts doing something with that incoming
tuple.I can see this log is executing in the node-2 (slave node).But,
interesting enough, despite receiving data in the master node, and confirming
its received, the logic that starts exactly below below that print statement
never executes in master node.The tuples received in master & slave are
unique.I thought it might be received in master, but then gets executed in
slave.But, that's not the case. The tuples arriving at master, never go through
the executing logic after the print statement.The slave on the other hand looks
normal receives data, and executes what its supposed to.Any ideas/suggestion
would be greatly appreciated.Thanks againAmir-
