Code Snippet :)
DataSet<Person> updatedPersonOne = inPerson.coGroup(inStudent)
.where("name").equalTo("name")
.with(new ComputeStudiesProfile());
DataSet<Person> updatedPersonTwo = updatedPersonOne.coGroup(inJobs)
.where("name").equalTo("name")
.with(new ComputeJobsProfile());
updatedPersonTwo.print();
On Wed, Jun 3, 2015 at 3:45 PM, Mustafa Elbehery <elbeherymust...@gmail.com>
wrote:
> 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
>
>
--
Mustafa Elbehery
EIT ICT Labs Master School <http://www.masterschool.eitictlabs.eu/home/>
+49(0)15750363097
skype: mustafaelbehery87
