flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chesnay Schepler <ches...@apache.org>
Subject Re: Check-pointing error
Date Thu, 29 Nov 2018 11:06:39 GMT
Please provide the full exception stack trace and version of Flink that 
you are using.

On 29.11.2018 11:55, Felipe Quirce wrote:
> Hi,
>
> I have found a problem during the checkpoint.
> Could anyone help me or help me to debug it?
> Exception:
>
>     1804 2018-11-29 11:31:00,448 INFO
>     org.apache.flink.runtime.executiongraph.ExecutionGraph -
>     keyedstats-processor-165 -> map2alert-165       -> Process ->
>     Sink: sink-level165 (1/2) (d860069560a4e3e6a62a450c9e3fa699)
>     switched from RUNNING to FAILED.
>     51805 java.io.IOException: Exception while applying
>     AggregateFunction in aggregating state
>     51806         at
>     org.apache.flink.runtime.state.heap.HeapAggregatingState.add(HeapAggregatingState.java:107)
>     51807         at
>     org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.processElement(WindowOperator.java:391)
>     51808         at
>     org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:202)
>     51809         at
>     org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:105)
>     51810         at
>     org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:300)
>     51811         at
>     org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)
>     51812         at java.lang.Thread.run(Thread.java:748)
>     51813 Caused by: java.lang.ArrayIndexOutOfBoundsException
>
>
> Thanks in Advance,



Mime
View raw message