You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by yuvraj singh <19...@gmail.com> on 2018/10/01 13:26:21 UTC

error with flink

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

Re: error with flink

Posted by yuvraj singh <19...@gmail.com>.

i am using 1.6.0



On Mon, Oct 1, 2018 at 8:05 PM Hequn Cheng <ch...@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 <19...@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
>>
>>
>>
>>

Re: error with flink

Posted by Hequn Cheng <ch...@gmail.com>.

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 <19...@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
>
>
>
>