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.bana...@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.
