NPE when checkpointing

2020-10-04 Thread Binh Nguyen Van
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:

Re: NPE when checkpointing

2020-10-09 Thread Binh Nguyen Van
his 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 streami

Re: NPE when checkpointing

2020-10-13 Thread Binh Nguyen Van
: > 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