Hi, I am trying to write two coGrouprs in sequence on the same ETL .. In use common dataset in both of them, in the first coGroup I update the initial dataset and retrieve the result in a new dataset object. Then I use the result in the second coGroup with another new dataset.
While debugging, I could see the coGroup.next is *false *, however, in the next iteration it has elements. I tried to force enabling ObjectReuse, I got *half* of the expected result. I have attached a screenshot for the debugger. My question is, does this has a relation about the concurrent execution of different tasks in Flink. And how to solve this problem ?? Regards. -- Mustafa Elbehery EIT ICT Labs Master School <http://www.masterschool.eitictlabs.eu/home/> +49(0)15750363097 skype: mustafaelbehery87
