Stephan Ewen wrote > This is actually not a bug, or a POJO or Avro problem. It is simply a > limitation in the functionality, as the exception message says: > "Specifying > fields by name is only supported on Case Classes (for now)." > > Try this with a regular reduce function that selects the max and it should > work fine...
Thanks. Just to be sure, this is also a limitation of the Java implementation of Flink, right? -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-avro-integration-tp3162p3236.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
