> this
>> problem for DataStreams.
>>
>> Regards,
>> Vinay Patil
>>
>>
>>
>>
>> --
>> Sent from:
>> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
>>
>>
>> --
>
Hi,
I am facing a similar issue today with Flink 1.6.0 - AvroOutputFormat
AvroOutputFormat tuple2AvroOutputFormat = new
AvroOutputFormat<>(
new Path(""), GenericRecord.class);
testDataSet
.map(new GenerateGenericRecord())
.returns(AvroTypeInfo.of(G
Flink should not interact poorly with heavily nested schemas. So this
might be another bug that is worth investigating. Can you share an
example that reproduces your issues with us? Which Flink version are you
using?
Contributors are always welcome :) I will also take a look into the
serializ
Hi Padarn,
usually people are using the AvroInputFormat with the Avro class
generated by an Avro schema. But after looking into the implementation,
one should also be able to use the GenericRecord class as a parameter.
So your exception seems to be a bug if it works locally but not
distribute
Hi all - sorry this seems like a silly question, but I can't figure it out.
I'm using an AvroInputFormat in order to read an Avro file like this:
val textInputFormat = new AvroInputFormat[GenericRecord](infile,
classOf[GenericRecord])
val lines = env.readFile(textInputFormat, path)
This works fi
