Hello, I ran into this exception while trying to call groupBy function. I thought all val(s) are already set to public by default. My class can be found here http://pastebin.com/EZuiP9XA
Any one has any idea how to fix it? Thank you. ====================================== log4j:WARN No appenders could be found for logger (org.apache.flink.api.java.typeutils.TypeExtractor). log4j:WARN Please initialize the log4j system properly. log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info. Exception in thread "main" java.lang.IllegalArgumentException: Key expressions are only supported on POJO types and Tuples. A type is considered a POJO if all its fields are public, or have both getters and setters defined at org.apache.flink.api.java.operators.Keys$ExpressionKeys.<init>(Keys.java:276) at org.apache.flink.api.scala.DataSet.groupBy(DataSet.scala:707) at vj.polimi.thesis.gmql.model.GmqlSampleSet.<init>(GmqlSampleSet.scala:35) at vj.polimi.thesis.test.GmqlFromNarrowPeak$.main(GmqlFromNarrowPeak.scala:63) at vj.polimi.thesis.test.GmqlFromNarrowPeak.main(GmqlFromNarrowPeak.scala) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:601) at com.intellij.rt.execution.application.AppMain.main(AppMain.java:134) ====================================== -- View this message in context: http://apache-flink-incubator-user-mailing-list-archive.2336050.n4.nabble.com/Exception-Key-expressions-are-only-supported-on-POJO-types-and-Tuples-tp720.html Sent from the Apache Flink (Incubator) User Mailing List archive. mailing list archive at Nabble.com.
