I could but only if there's a good probability that it fix the problem...how confident are you about it?
On Wed, Apr 19, 2017 at 8:27 PM, Ted Yu <yuzhih...@gmail.com> wrote: > 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(BatchT >> ask.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.readUnsi >> gnedByte(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.ReusingDeserializationDele >> gate.read(ReusingDeserializationDelegate.java:57) >> at org.apache.flink.runtime.io.network.api.serialization.Spilli >> ngAdaptiveSpanningRecordDeserializer.getNextRecord(SpillingA >> daptiveSpanningRecordDeserializer.java:144) >> at org.apache.flink.runtime.io.network.api.reader.AbstractRecor >> dReader.getNextRecord(AbstractRecordReader.java:72) >> at org.apache.flink.runtime.io.network.api.reader.MutableRecord >> Reader.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 >> > >
