Flink集群运行JAR包时无法访问resources目录下CSV文件问题求助

你当前的报错核心是JAR包内的资源路径无法被Flink的本地文件系统识别：

• 本地运行时，资源存放在项目编译后的classes目录下，是文件系统中真实存在的独立文件/目录，getResource.getPath()返回的是标准文件路径，可以被正常读取。
• 集群运行时，所有代码都在上传的JAR包内，getResource.getPath()返回的是带!/分隔符的JAR包内部资源路径，这种路径不属于标准文件路径，Flink的LocalFileSystem无法解析，所以抛出文件不存在异常。

• 方案1：直接通过流读取资源（最推荐，无额外依赖）
  不要尝试获取资源的文件路径，直接读取资源流操作，适配本地和JAR包两种运行场景，示例代码如下：

// 直接读取JAR包内的csv文件流
try (InputStream inputStream = Helper.class.getClassLoader().getResourceAsStream("ldbc_sample/edges.csv");
     BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream))) {
    // 按行读取csv内容处理即可
    String line;
    while ((line = reader.readLine()) != null) {
        // 处理每行数据
    }
} catch (IOException e) {
    // 异常处理逻辑
}

• 方案2：将资源导出到本地临时目录（适配必须传入文件路径的场景）
  如果你的业务逻辑/依赖组件必须传入标准文件路径才能运行，可以在程序初始化阶段将JAR包内的资源导出到集群节点的本地临时目录，再使用临时文件的路径，示例代码：

public String getResourceTmpPath(String resourcePath) throws IOException {
    // 读取资源流
    InputStream inputStream = Helper.class.getClassLoader().getResourceAsStream(resourcePath);
    // 创建临时文件
    File tmpFile = File.createTempFile("tmp_", ".csv");
    tmpFile.deleteOnExit();
    // 将资源流写入临时文件
    Files.copy(inputStream, tmpFile.toPath(), StandardCopyOption.REPLACE_EXISTING);
    // 返回临时文件的绝对路径
    return tmpFile.getAbsolutePath();
}
// 调用方式：
// String csvPath = getResourceTmpPath("ldbc_sample/edges.csv");

• 方案3：上传到共享存储（适合大文件场景）
  如果CSV文件体积较大，可以提前将文件上传到集群所有节点都能访问的共享存储（如HDFS、NAS），代码中直接使用共享存储的路径访问即可，无需打包到JAR包中。

内容的提问来源于stack exchange，提问作者nanobot