Ah, yes of course. Yassine is right, thanks! Sorry for not spotting this earlier. Will close the JIRA issue.
Best, Fabian 2017-02-18 12:48 GMT+01:00 Yassine MARZOUGUI <y.marzou...@mindlytix.com>: > Hi, > > I think this is an expected output and not necessarily a bug. To get the > element having the maximum value, maxBy() should be used instead of max(). > > See this answer for more details : http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/Wrong-and-non- > consistent-behavior-of-max-tp484p488.html > > Best, > Yassine > > On Feb 18, 2017 12:28, "Kürşat Kurt" <kur...@kursatkurt.com> wrote: > > 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 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; > > > > 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; *ds.groupBy(0).max(4).print() *prints : > > > > *(0,Sports,0.4,1,1.7495261699956258E-4)* > > *(1,Sports,0.4,1,1.7495261699956258E-4)* > > > > ..but i am expecting > > > > *(0,Sports,0.4,2,1.7495261699956258E-4)* > > *(1,Auto,0.4,1,1.7495261699956258E-4)* > > > > What is wrong with this code? > > > > >
