Flink Table API 1.15.1 Filesystem Connector不可用问题求助

• 问题根源：filesystem是Flink的外置连接器组件，核心依赖包不包含该模块，导致运行时无法找到匹配的DynamicTableFactory实现类。

• Maven项目添加依赖：在pom.xml中引入对应版本的连接器依赖：

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-filesystem</artifactId>
    <version>1.15.1</version>
    <!-- 集群运行时可将scope改为provided，避免包冲突 -->
    <scope>compile</scope>
</dependency>

• Gradle项目添加依赖：在build.gradle中添加：

implementation 'org.apache.flink:flink-connector-filesystem:1.15.1'
// 集群部署场景改用provided
// provided 'org.apache.flink:flink-connector-filesystem:1.15.1'

• 本地IDE运行调整：IDE直接运行时，确保依赖scope为compile（Maven）或implementation（Gradle），这样IDE会自动将依赖包加入类路径；若之前用了provided，IDE运行时会找不到该包，需调整scope。

• 集群部署方案：

  • 方案一：将flink-connector-filesystem-1.15.1.jar放入集群节点的lib目录，重启集群后再提交作业
  • 方案二：提交作业时通过-j参数指定依赖包路径，示例命令：

    flink run -j flink-connector-filesystem-1.15.1.jar your-job.jar
    

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