Apache Flink容器重启后出现No FileSystem for scheme 'file'错误

从报错No FileSystem for scheme "file"来看，核心是重启后Flink在Checkpoint最终化阶段无法找到本地文件系统的实现类，这大概率和Hadoop依赖兼容性、插件加载异常有关，以下是针对性的解决步骤：

1. 替换兼容Java17的Hadoop依赖包 #

你当前使用的flink-shaded-hadoop2-uber-2.8.3-1.8.3.jar基于Hadoop 2.8.x版本，仅支持Java 8，和flink:java17镜像存在兼容性问题，会导致Hadoop的FileSystem类加载异常。建议换成适配Java17的Flink shaded Hadoop 3版本包（比如对应Flink 1.17的flink-shaded-hadoop-3-uber-3.1.1-17.0.jar，版本需匹配你的Flink具体版本），替换/opt/flink/lib下的旧包。

2. 显式指定本地文件系统实现 #

在flink-conf.yaml中添加以下配置，强制指定Hadoop本地文件系统的实现类，避免Flink找不到"file" scheme的处理逻辑：

fs.file.impl: org.apache.hadoop.fs.LocalFileSystem

3. 检查插件目录权限 #

容器重启后，/opt/flink/plugins/azure-fs/目录权限可能被重置，导致Flink无法读取flink-azure-fs-hadoop.jar。进入容器执行命令检查权限：

ls -l /opt/flink/plugins/azure-fs/

如果权限不是flink用户（Flink默认运行用户）可读写，执行以下命令修正：

chown -R flink:flink /opt/flink/plugins/azure-fs/

4. 排除任务项目中的冲突依赖 #

如果你的任务项目中引入了Hadoop相关依赖，需要将其设置为provided scope，避免打包到任务jar中与集群的Hadoop依赖冲突。比如Maven配置：

<dependency>
    <groupId>org.apache.hadoop</groupId>
    <artifactId>hadoop-common</artifactId>
    <version>对应集群的Hadoop版本</version>
    <scope>provided</scope>
</dependency>

5. 验证插件加载状态 #

重启容器后，查看Flink的jobmanager.log或taskmanager.log，搜索关键词AzureFileSystem或FileSystem，确认插件是否成功加载。如果日志中出现Loaded plugin azure-fs相关信息，说明插件加载正常；如果有Failed to load plugin报错，需检查插件jar的完整性和权限。

另外，重启后不需要额外配置ABFS——你已经在flink-conf.yaml中配置了账号密钥和存储路径，问题根源不在ABFS本身，而是本地文件系统的实现加载异常导致Checkpoint最终化失败。

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