(DEPRECATED) Apache Flink User Mailing List archive.

error with flink

classic Classic list List threaded Threaded
♦
♦
 3 messages Options
yuvraj singh
Reply | Threaded
Open this post in threaded view
♦
♦
|

error with flink

yuvraj singh

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
Hequn Cheng
Reply | Threaded
Open this post in threaded view
♦
♦
|

Re: error with flink

Hequn Cheng
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 <[hidden email]> 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
yuvraj singh
Reply | Threaded
Open this post in threaded view
♦
♦
|

Re: error with flink

yuvraj singh
i am using 1.6.0 



On Mon, Oct 1, 2018 at 8:05 PM Hequn Cheng <[hidden email]> 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 <[hidden email]> 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
Free forum by Nabble Edit this page