Re: NPE when checkpointing

No worries, thanks for the update! It's good to hear that it worked for you. Best regards, Piotrek wt., 13 paź 2020 o 22:43 Binh Nguyen Van napisał(a): > Hi, > > Sorry for the late reply. It took me quite a while to change the JDK > version to reproduce the issue. I confirmed that if I upgrade

Re: NPE when checkpointing

Hi, Sorry for the late reply. It took me quite a while to change the JDK version to reproduce the issue. I confirmed that if I upgrade to a newer JDK version (I tried with JDK 1.8.0_265) the issue doesn’t happen. Thank you for helping -Binh On Fri, Oct 9, 2020 at 11:36 AM Piotr Nowojski wrote:

Re: NPE when checkpointing

Hi Binh, Could you try upgrading Flink's Java runtime? It was previously reported that upgrading to jdk1.8.0_251 was solving the problem. Piotrek pt., 9 paź 2020 o 19:41 Binh Nguyen Van napisał(a): > Hi, > > Thank you for helping me! > The code is compiled on > > java version "1.8.0_161" > Jav

Re: NPE when checkpointing

Hi, Thank you for helping me! The code is compiled on java version "1.8.0_161" Java(TM) SE Runtime Environment (build 1.8.0_161-b12) Java HotSpot(TM) 64-Bit Server VM (build 25.161-b12, mixed mode) But I just checked our Hadoop and its Java version is java version "1.8.0_77" Java(TM) SE Runtime

Re: NPE when checkpointing

Hi, One more thing. It looks like it's not a Flink issue, but some JDK bug. Others reported that upgrading JDK version (for example to jdk1.8.0_251) seemed to be solving this problem. What JDK version are you using? Piotrek pt., 9 paź 2020 o 17:59 Piotr Nowojski napisał(a): > Hi, > > Thanks f

Re: NPE when checkpointing

Hi, Thanks for reporting the problem. I think this is a known issue [1] on which we are working to fix. Piotrek [1] https://issues.apache.org/jira/browse/FLINK-18196 pon., 5 paź 2020 o 08:54 Binh Nguyen Van napisał(a): > Hi, > > I have a streaming job that is written in Apache Beam and uses F

NPE when checkpointing

Hi, I have a streaming job that is written in Apache Beam and uses Flink as its runner. The job is working as expected for about 15 hours and then it started to have checkpointing error. The error message looks like this java.lang.Exception: Could not perform checkpoint 910 for operator Source: