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.
Example:
this is the content
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).pr
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 DataSet>> where, at a
> certain poin
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)*
>
> *(0,Computer,0.2,1,4.8828125E-5)*
>
>
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
*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 :
Hi;
I have a Dataset like this:
*(**0,Auto,0.4,1,5.831753899
rşat Kurt" 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
>
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
@flink.apache.org
Subject: 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 <mailto:user@flink.apache.org>
Subject: RE: Aggregation problem.
Hi,
I
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.
>
>
>
> F
, 2017 3:34 PM
To: user@flink.apache.org
Cc: Kürşat Kurt
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 - if compiled from sources -
try
.org
> Cc: Kürşat Kurt
> 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 - if compiled from s
il 13, 2017 5:07 PM
To: Kürşat Kurt
Cc: user@flink.apache.org
Subject: Re: Aggregation problem.
I failed to reproduce your error.
How did you set up your project: SBT, Maven?
Maybe its dependency management is referring to an old version of flink? Maybe
different versions of scala are mixed?
In
13 matches
Mail list logo
