i am using 1.6.0
On Mon, Oct 1, 2018 at 8:05 PM Hequn Cheng <chenghe...@gmail.com> wrote: > Hi yuvraj, > > It seems a null key has been keyed by. Which Flink version do you use? And > could you show some user code related about keyBy or GroupBy? > > Best, Hequn > > On Mon, Oct 1, 2018 at 9:26 PM yuvraj singh <19yuvrajsing...@gmail.com> > wrote: > >> Hi i am facing this problem with my flink job please help me with it . >> >> >> >> >> java.lang.Exception: An async function call terminated with an exception. >> Failing the AsyncWaitOperator. >> >> at >> org.apache.flink.streaming.api.operators.async.Emitter.output(Emitter.java:137) >> >> at >> org.apache.flink.streaming.api.operators.async.Emitter.run(Emitter.java:85) >> >> at java.lang.Thread.run(Thread.java:745) >> >> Caused by: java.lang.RuntimeException >> >> at >> org.apache.flink.streaming.runtime.io.RecordWriterOutput.pushToRecordWriter(RecordWriterOutput.java:110) >> >> at >> org.apache.flink.streaming.runtime.io.RecordWriterOutput.collect(RecordWriterOutput.java:89) >> >> at >> org.apache.flink.streaming.runtime.io.RecordWriterOutput.collect(RecordWriterOutput.java:45) >> >> at >> org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:689) >> >> at >> org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:667) >> >> at >> org.apache.flink.streaming.api.operators.TimestampedCollector.collect(TimestampedCollector.java:51) >> >> at >> org.apache.flink.streaming.api.operators.async.Emitter.output(Emitter.java:133) >> >> ... 2 more >> >> Caused by: java.lang.NullPointerException >> >> at >> org.apache.flink.runtime.state.KeyGroupRangeAssignment.assignToKeyGroup(KeyGroupRangeAssignment.java:59) >> >> at >> org.apache.flink.runtime.state.KeyGroupRangeAssignment.assignKeyToParallelOperator(KeyGroupRangeAssignment.java:48) >> >> at >> org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitioner.selectChannels(KeyGroupStreamPartitioner.java:63) >> >> at >> org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitioner.selectChannels(KeyGroupStreamPartitioner.java:32) >> >> at >> org.apache.flink.runtime.io.network.api.writer.RecordWriter.emit(RecordWriter.java:104) >> >> at >> org.apache.flink.streaming.runtime.io.StreamRecordWriter.emit(StreamRecordWriter.java:81) >> >> at >> org.apache.flink.streaming.runtime.io.RecordWriterOutput.pushToRecordWriter(RecordWriterOutput.java:107) >> >> ... 8 more >> >> >> >>
