flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Felipe Quirce <pipe....@gmail.com>
Subject Check-pointing error
Date Thu, 29 Nov 2018 10:55:22 GMT
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