Looking at git log of DataInputDeserializer.java , there has been some recent change.
If you have time, maybe try with 1.2.1 RC and see if the error is reproducible ? Cheers On Wed, Apr 19, 2017 at 11:22 AM, Flavio Pompermaier <pomperma...@okkam.it> wrote: > Hi to all, > I think I'm again on the weird Exception with the > SpillingAdaptiveSpanningRecordDeserializer... > I'm using Flink 1.2.0 and the error seems to rise when Flink spills to > disk but the Exception thrown is not very helpful. Any idea? > > Caused by: java.lang.RuntimeException: Error obtaining the sorted input: > Thread 'SortMerger Reading Thread' terminated due to an exception: null > at org.apache.flink.runtime.operators.sort.UnilateralSortMerger. > getIterator(UnilateralSortMerger.java:619) > at org.apache.flink.runtime.operators.BatchTask.getInput( > BatchTask.java:1094) > at org.apache.flink.runtime.operators.GroupReduceDriver. > prepare(GroupReduceDriver.java:99) > at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:460) > ... 3 more > Caused by: java.io.IOException: Thread 'SortMerger Reading Thread' > terminated due to an exception: null > at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ > ThreadBase.run(UnilateralSortMerger.java:799) > Caused by: java.io.EOFException > at org.apache.flink.runtime.util.DataInputDeserializer.readUnsignedByte( > DataInputDeserializer.java:306) > at org.apache.flink.types.StringValue.readString(StringValue.java:747) > at org.apache.flink.api.common.typeutils.base. > StringSerializer.deserialize(StringSerializer.java:69) > at org.apache.flink.api.common.typeutils.base. > StringSerializer.deserialize(StringSerializer.java:74) > at org.apache.flink.api.common.typeutils.base. > StringSerializer.deserialize(StringSerializer.java:28) > at org.apache.flink.api.java.typeutils.runtime.RowSerializer.deserialize( > RowSerializer.java:193) > at org.apache.flink.api.java.typeutils.runtime.RowSerializer.deserialize( > RowSerializer.java:36) > at org.apache.flink.runtime.plugable.ReusingDeserializationDelegate.read( > ReusingDeserializationDelegate.java:57) > at org.apache.flink.runtime.io.network.api.serialization. > SpillingAdaptiveSpanningRecordDeserializer.getNextRecord( > SpillingAdaptiveSpanningRecordDeserializer.java:144) > at org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader. > getNextRecord(AbstractRecordReader.java:72) > at org.apache.flink.runtime.io.network.api.reader. > MutableRecordReader.next(MutableRecordReader.java:42) > at org.apache.flink.runtime.operators.util.ReaderIterator. > next(ReaderIterator.java:59) > at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ > ReadingThread.go(UnilateralSortMerger.java:1035) > at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ > ThreadBase.run(UnilateralSortMerger.java:796) > > > Best, > Flavio >
