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.