flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: error in reduceGroup operator when changing the Flink version from 0.7 to 0.8
Date Tue, 24 Feb 2015 10:37:24 GMT
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<Long> numVertices
edges.<Tuple1<Long>>project(1)).distinct().reduceGroup(new
CountVertices())

On Tue, Feb 24, 2015 at 11:19 AM, HungChang <unicorn.banachi@gmail.com> wrote:
> 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-reduceGroup-operator-when-changing-the-Flink-version-from-0-7-to-0-8-tp785p789.html
> Sent from the Apache Flink (Incubator) User Mailing List archive. mailing list archive
at Nabble.com.

Mime
View raw message