Re: Example - Reading Avro Generic records

Tranadeep, Also, in your code example, when *reuseAvroValue* is *false* the code will fail with this message: java.lang.RuntimeException: The class 'org.apache.avro.generic.GenericRecord' is not instantiable: The class is no proper class, it is either abstract, an interface, or a primitive type.

Re: Example - Reading Avro Generic records

Tranadeep, Thanks for pasting your code! I have a PR ready that extends AvroInputFormat and will submit it soon. Still waiting for the legal team at AOL to approve it. -Gna On Sat, Apr 2, 2016 at 5:36 PM, Tarandeep Singh wrote: > Thank you Gna for opening the ticket. >

Re: Example - Reading Avro Generic records

There is a way yet, but I am proposing to do one: https://issues.apache.org/jira/browse/FLINK-3691 On Fri, Apr 1, 2016 at 4:04 AM, Tarandeep Singh wrote: > Hi, > > Can someone please point me to an example of creating DataSet using Avro > Generic Records? > > I tried this

Re: Example - Reading Avro Generic records

Tarandeep, There isn't a way yet, but I am proposing to do one: https://issues.apache.org/jira/browse/FLINK-3691 -Gna On Fri, Apr 1, 2016 at 4:04 AM, Tarandeep Singh wrote: > Hi, > > Can someone please point me to an example of creating DataSet using Avro > Generic

Example - Reading Avro Generic records

Hi, Can someone please point me to an example of creating DataSet using Avro Generic Records? I tried this code - final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment(); final Path iPath = new Path(args[0]); DataSet dataSet = env.createInput(new