Re: Flink+avro integration

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

Re: Flink+avro integration

Till Rohrmann wrote > What was your problem with using Java POJOs with the Scala API? Here's a quick example that demonstrates some of the problems I'm having. I used `max` in the example, but actually I get an exception for most of

Re: Flink+avro integration

One more follow up: There doesn't appear to be an official avro library for Scala. How would you recommend integrating Avro in a Scala project? The most straightforward option seems to be to just use the Java library, but Scala Flink operations don't work on Java POJOs, as far as I could tell. Doe

Re: Flink+avro integration

Stephan, Thanks for the quick reply and the example. That does help! -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-avro-integration-tp3162p3185.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabbl