有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

HDFS上的java文件,用于初始化Flink作业中的对象

我对Flink有一个奇怪的问题:在一个作业中,我必须用预编译的资源文件初始化一个对象。作业开始后,第一次运行时不会出现问题。但当我像第一次一样使用web界面再次访问它时,我的对象无法初始化,错误是:

java.nio.file.NoSuchFileException: hdfs:/.../.../my_file

这让我很困惑,因为文件就在那里,对象在第一次成功初始化。相关代码为:

Config.load(Files.newBufferedReader(
    Paths.get("hdfs:///xx/xx/myconfig.cfg"),
    StandardCharsets.UTF_8));

如果资源在本地系统上,并且我使用相同的作业运行本地服务器,我不会遇到任何问题。有人有线索吗

编辑:完整跟踪

Caused by: java.nio.file.NoSuchFileException: hdfs:/path/to/xx.cfg
at sun.nio.fs.UnixException.translateToIOException(UnixException.java:86)
at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:102)
at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:107)
at sun.nio.fs.UnixFileSystemProvider.newByteChannel(UnixFileSystemProvider.java:214)
at java.nio.file.Files.newByteChannel(Files.java:361)
at java.nio.file.Files.newByteChannel(Files.java:407)
at java.nio.file.spi.FileSystemProvider.newInputStream(FileSystemProvider.java:384)
at java.nio.file.Files.newInputStream(Files.java:152)
at java.nio.file.Files.newBufferedReader(Files.java:2784)
at myObject(myObject.java:364)
at myclass$mymethod.map(myclass.java:126)
at myclass$mymethod.map(myclass.java:1)
at org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:35)
at org.apache.flink.streaming.runtime.tasks.OutputHandler$CopyingOperatorCollector.collect(OutputHandler.java:272)
... 7 more

共 (0) 个答案