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,
