Re: Aggregation problem.

apache.org > Cc: Kürşat Kurt <kur...@kursatkurt.com> > Subject: Re: Aggregation problem. > > maxBy() is still a member of org.apache.flink.api.scala.GroupedDataSet in > the current sources - what did you upgrade flink to? > > Also please make sure the new version is used, or - i

RE: Aggregation problem.

, 2017 3:34 PM To: user@flink.apache.org Cc: Kürşat Kurt <kur...@kursatkurt.com> Subject: Re: Aggregation problem. maxBy() is still a member of org.apache.flink.api.scala.GroupedDataSet in the current sources - what did you upgrade flink to? Also please make sure the new version i

Re: Aggregation problem.

et > > > > > > > > From: Kürşat Kurt [mailto:kur...@kursatkurt.com] > Sent: Sunday, February 19, 2017 1:28 AM > To: user@flink.apache.org > Subject: RE: Aggregation problem. > > > > Yes, it works. > > Thank you Yassine. > > > &

RE: Aggregation problem.

Yes, it works. Thank you Yassine. From: Yassine MARZOUGUI [mailto:y.marzou...@mindlytix.com] Sent: Saturday, February 18, 2017 2:48 PM To: user@flink.apache.org Subject: RE: Aggregation problem. Hi, I think this is an expected output and not necessarily a bug. To get the element

Re: Aggregation problem.

@gmail.com] > *Sent:* Saturday, February 18, 2017 3:33 AM > *To:* user@flink.apache.org > *Subject:* Re: Aggregation problem. > > > > Hi, > > this looks like a bug to me. > > Can you open a JIRA and maybe a small testcase to reproduce the issue? > > Thank you, &g

RE: Aggregation problem.

ruary 18, 2017 3:33 AM *To:* user@flink.apache.org *Subject:* Re: Aggregation problem. Hi, this looks like a bug to me. Can you open a JIRA and maybe a small testcase to reproduce the issue? Thank you, Fabian 2017-02-18 1:06 GMT+01:00 Kürşat Kurt <kur...@kursatkurt.com>: Hi;

RE: Aggregation problem.

Ok, i have opened the issue with the test case. Thanks. https://issues.apache.org/jira/browse/FLINK-5840 From: Fabian Hueske [mailto:fhue...@gmail.com] Sent: Saturday, February 18, 2017 3:33 AM To: user@flink.apache.org Subject: Re: Aggregation problem. Hi, this looks like

Re: Aggregation problem.

Hi, this looks like a bug to me. Can you open a JIRA and maybe a small testcase to reproduce the issue? Thank you, Fabian 2017-02-18 1:06 GMT+01:00 Kürşat Kurt : > Hi; > > > > I have a Dataset like this: > > > > *(**0,Auto,0.4,1,5.8317538999854194E-5)* > >

Aggregation problem.

Hi; I have a Dataset like this: (0,Auto,0.4,1,5.8317538999854194E-5) (0,Computer,0.2,1,4.8828125E-5) (0,Sports,0.4,2,1.7495261699956258E-4) (1,Auto,0.4,1,1.7495261699956258E-4) (1,Computer,0.2,1,4.8828125E-5) (1,Sports,0.4,1,5.8317538999854194E-5) This code;

Re: aggregation problem

Hi Riccardo, can you please be a bit more specific? What do you mean by "it didn't work"? Did it crash? Did it give you a wrong value? Something else? -Vasia. On 28 April 2016 at 16:52, Riccardo Diomedi wrote: > Hi everybody > > In a DeltaIteration I have a

aggregation problem

Hi everybody In a DeltaIteration I have a DataSet> where, at a certain point of the iteration, i need to count the total number of tuples and the total number of elements in the HashSet of each tuple, and then send both value to the ConvergenceCriterion function.