Re: Flink - Avro - AvroTypeInfo issue - Index out of bounds exception

2015-04-21 Thread Stephan Ewen
Hi! >From a quick look at the code it seems that this is a followup exception that occurs because the task has been shut down and the buffer pools destroyed. Is there another root exception that is the root cause of the failure? Greetings, Stephan On Tue, Apr 21, 2015 at 5:46 PM, Filip Łęczyck

Re: Flink - Avro - AvroTypeInfo issue - Index out of bounds exception

2015-04-21 Thread Filip Łęczycki
Hi guys, Thank you very much for you help, upgarding to the 0.9.0-milestone resolved the issue but the new one arised. While trying to run the following code: val job = Job.getInstance(new Configuration(true)) ParquetInputFormat.setReadSupportClass(job, classOf[AvroReadSupport[AlignmentRecord]])