flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Felipe Quirce <pipe....@gmail.com>
Subject Re: Check-pointing error
Date Thu, 29 Nov 2018 11:11:13 GMT
Hi

I'm using the flink 1.6.2, and full stack trace is

java.io.IOException: Exception while applying AggregateFunction in
aggregating state
 4308         at
org.apache.flink.runtime.state.heap.HeapAggregatingState.add(HeapAggregatingState.java:107)
 4309         at
org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.processElement(WindowOperator.java:391)
 4310         at
org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:202)
 4311         at
org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:105)
 4312         at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:300)
 4313         at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)
 4314         at
java.lang.Thread.run(Thread.java:748)
 4315 Caused by: java.lang.ArrayIndexOutOfBoundsException:
-1
 4316         at
com.esotericsoftware.kryo.util.IntArray.pop(IntArray.java:157)
 4317         at
com.esotericsoftware.kryo.Kryo.reference(Kryo.java:822)
 4318         at
com.esotericsoftware.kryo.serializers.CollectionSerializer.copy(CollectionSerializer.java:129)
 4319         at
com.esotericsoftware.kryo.serializers.CollectionSerializer.copy(CollectionSerializer.java:22)
 4320         at
com.esotericsoftware.kryo.Kryo.copy(Kryo.java:862)
 4321         at
org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer.copy(KryoSerializer.java:217)
 4322         at
org.apache.flink.api.java.typeutils.runtime.PojoSerializer.copy(PojoSerializer.java:239)
 4323         at
org.apache.flink.api.scala.typeutils.TraversableSerializer$$anonfun$copy$1.apply(TraversableSerializer.scala:69)
 4324         at
org.apache.flink.api.scala.typeutils.TraversableSerializer$$anonfun$copy$1.apply(TraversableSerializer.scala:69)
 4325         at
scala.collection.immutable.List.foreach(List.scala:392)
 4326         at
org.apache.flink.api.scala.typeutils.TraversableSerializer.copy(TraversableSerializer.scala:69)
 4327         at
org.apache.flink.api.scala.typeutils.TraversableSerializer.copy(TraversableSerializer.scala:33)
 4328         at
org.apache.flink.api.scala.typeutils.CaseClassSerializer.copy(CaseClassSerializer.scala:101)
 4329         at
org.apache.flink.api.scala.typeutils.CaseClassSerializer.copy(CaseClassSerializer.scala:32)
 4330         at
org.apache.flink.api.scala.typeutils.TraversableSerializer$$anonfun$copy$1.apply(TraversableSerializer.scala:69)
 4331         at
org.apache.flink.api.scala.typeutils.TraversableSerializer$$anonfun$copy$1.apply(TraversableSerializer.scala:69)
 4332         at
scala.collection.Iterator$class.foreach(Iterator.scala:891)
 4333         at
scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
 4334         at
scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
 4335         at
scala.collection.AbstractIterable.foreach(Iterable.scala:54)
 4336         at
org.apache.flink.api.scala.typeutils.TraversableSerializer.copy(TraversableSerializer.scala:69)
 4337         at
org.apache.flink.api.scala.typeutils.TraversableSerializer.copy(TraversableSerializer.scala:33)
 4338         at
org.apache.flink.runtime.state.heap.CopyOnWriteStateTable.transform(CopyOnWriteStateTable.java:465)
 4339         at
org.apache.flink.runtime.state.heap.CopyOnWriteStateTable.transform(CopyOnWriteStateTable.java:341)
 4340         at
org.apache.flink.runtime.state.heap.HeapAggregatingState.add(HeapAggregatingState.java:105)
 4341         ... 6 more

Thanks

On Thu, 29 Nov 2018 at 11:55, Felipe Quirce <pipe.235@gmail.com> 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