Thanks Congxian & Vino. Yes, the file do exist and I don't see any problem in accessing it.
Regarding flink 1.9, we haven't migrated yet but we are planning to do. Since we have to test it might take sometime. Thanks On Fri, Jan 3, 2020 at 2:14 AM Congxian Qiu <qcx978132...@gmail.com> wrote: > Hi > > Do you have ever check that this problem exists on Flink 1.9? > > Best, > Congxian > > > vino yang <yanghua1...@gmail.com> 于2020年1月3日周五 下午3:54写道： > >> Hi Navneeth, >> >> Did you check if the path contains in the exception is really can not be >> found? >> >> Best, >> Vino >> >> Navneeth Krishnan <reachnavnee...@gmail.com> 于2020年1月3日周五 上午8:23写道： >> >>> Hi All, >>> >>> We are running into checkpoint timeout issue more frequently in >>> production and we also see the below exception. We are running flink 1.4.0 >>> and the checkpoints are saved on NFS. Can someone suggest how to overcome >>> this? >>> >>> [image: image.png] >>> >>> java.lang.IllegalStateException: Could not initialize operator state >>> backend. >>> at >>> org.apache.flink.streaming.api.operators.AbstractStreamOperator.initOperatorState(AbstractStreamOperator.java:302) >>> at >>> org.apache.flink.streaming.api.operators.AbstractStreamOperator.initializeState(AbstractStreamOperator.java:249) >>> at >>> org.apache.flink.streaming.runtime.tasks.StreamTask.initializeOperators(StreamTask.java:692) >>> at >>> org.apache.flink.streaming.runtime.tasks.StreamTask.initializeState(StreamTask.java:679) >>> at >>> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:253) >>> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:718) >>> at java.lang.Thread.run(Thread.java:748) >>> Caused by: java.io.FileNotFoundException: >>> /mnt/checkpoints/02c4f8d5c11921f363b98c5959cc4f06/chk-101/e71d8eaf-ff4a-4783-92bd-77e3d8978e01 >>> (No such file or directory) >>> at java.io.FileInputStream.open0(Native Method) >>> at java.io.FileInputStream.open(FileInputStream.java:195) >>> at java.io.FileInputStream.<init>(FileInputStream.java:138) >>> at >>> org.apache.flink.core.fs.local.LocalDataInputStream.<init>(LocalDataInputStream.java:50) >>> >>> >>> Thanks >>> >>>
