Hi Amir, I'm not sure whether I understood your question. Which print function are you using? Note that the master won't print anything if you use Flink's print API. I think you'll have to share some code so we can see what is going on.
Cheers, Max On Tue, Jun 7, 2016 at 2:01 AM, amir bahmanyari <[email protected]> wrote: > 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 again > Amir-
