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,
