Re: Check-pointing error

Thu, 29 Nov 2018 03:51:02 -0800

Would it be possible for you to try this with 1.6-SNAPSHOT? This issue may have been fixed with https://issues.apache.org/jira/browse/FLINK-10839. 

On 29.11.2018 12:11, Felipe Quirce wrote:

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 <[email protected] <mailto:[email protected]>> 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,

Reply via email to