Thank you!This is complete solving the problem.
--
View this message in context:
http://apache-flink-incubator-user-mailing-list-archive.2336050.n4.nabble.com/Error-in-reduceGroup-operator-when-changing-the-Flink-version-from-0-7-to-0-8-tp785p793.html
Sent from the Apache Flink (Incubator) Us
The problem is that someone changed how project() works. Sorry for the
inconvenience. To make it work, you have to add the type parameter
manually, so that the result of project() has the correct type:
DataSet numVertices
edges.>project(1)).distinct().reduceGroup(new
CountVertices())
On Tue, Feb
Thanks for your reply.
The error is from java compiler (Eclipse).
It looks like the data type of output and input are OK in 0.7 version, but
not proper in 0.8 version.
--
View this message in context:
http://apache-flink-incubator-user-mailing-list-archive.2336050.n4.nabble.com/Error-in-reduce
Hi Hung!
Can you tell us who exactly gives you that error? The java compiler, or
Flink, when you run the program?
If it is Flink, can you attach the stack trace of the exception?
Greetings,
Stephan
On Tue, Feb 24, 2015 at 10:50 AM, HungChang
wrote:
> Hi, when changing the version from 0.7 to
Hi, when changing the version from 0.7 to 0.8, reduceGroup operator gets the
following error:
"The method reduceGroup(GroupReduceFunction) in the type
DataSet is not applicable for the arguments
(InDegreeDistribution.CountVertices)"
Tried to figure out the error but failed to fix it. Could you pl
