flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Mustafa Elbehery <elbeherymust...@gmail.com>
Subject Re: coGroup Iterator NoSuchElement
Date Wed, 03 Jun 2015 13:50:59 GMT
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 <elbeherymustafa@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

Mime
View raw message