You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "JieFang.He (Jira)" <ji...@apache.org> on 2020/08/28 01:54:00 UTC

[jira] [Created] (FLINK-19067) FileNotFoundException when run flink examples on standby JobManager

JieFang.He created FLINK-19067:
----------------------------------

             Summary: FileNotFoundException when run flink examples on standby JobManager
                 Key: FLINK-19067
                 URL: https://issues.apache.org/jira/browse/FLINK-19067
             Project: Flink
          Issue Type: Bug
    Affects Versions: 1.11.1
            Reporter: JieFang.He


1、When run examples/batch/WordCount.jar on standby JobManager,it will fail with the exception:

Caused by: java.io.FileNotFoundException: /data2/storageDir/default/blob/job_d29414828f614d5466e239be4d3889ac/blob_p-a2ebe1c5aa160595f214b4bd0f39d80e42ee2e93-f458f1c12dc023e78d25f191de1d7c4b (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)
 at org.apache.flink.core.fs.local.LocalFileSystem.open(LocalFileSystem.java:143)
 at org.apache.flink.runtime.blob.FileSystemBlobStore.get(FileSystemBlobStore.java:105)
 at org.apache.flink.runtime.blob.FileSystemBlobStore.get(FileSystemBlobStore.java:87)
 at org.apache.flink.runtime.blob.BlobServer.getFileInternal(BlobServer.java:501)
 at org.apache.flink.runtime.blob.BlobServerConnection.get(BlobServerConnection.java:231)
 at org.apache.flink.runtime.blob.BlobServerConnection.run(BlobServerConnection.java:117)

 

2、Run examples success on other nodes

3、After run success on the other node, it can run success on the Standby JobManager. But run again will fail

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)