Re: Check-pointing error

2018-12-02 Thread Congxian Qiu
Hi,Felipe Quirce Could you reproduce this in stand alone mode? or could you share your code? Best Congxian Felipe Quirce 于2018年11月30日周五 下午9:34写道: > Hi Chesnay, > > I tried with the version 1.7.0 and I had the same error. > > 2018-11-30 13:13:00,718 INFO org.apache.flink.runtime.taskmanager.Ta

Re: Check-pointing error

2018-11-30 Thread Felipe Quirce
Hi Chesnay, I tried with the version 1.7.0 and I had the same error. 2018-11-30 13:13:00,718 INFO org.apache.flink.runtime.taskmanager.Task - keyedstats-processor-165 -> map2alert-165 -> Process -> Sink: sink-level165 (1/4) (a972c963d4ee576a88c9116e946eec62) switched from RUNN

Re: Check-pointing error

2018-11-29 Thread Chesnay Schepler
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 Aggr

Re: Check-pointing error

2018-11-29 Thread Felipe Quirce
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.runti

Re: Check-pointing error

2018-11-29 Thread Chesnay Schepler
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

Check-pointing error

2018-11-29 Thread Felipe Quirce
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) (d