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 <[email protected]> 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 > > > >
