Flink表api文件系统连接器不可用



我正在尝试使用flink table api(1.15.1版本(写入本地文件系统。我正在使用TableDescriptor.forConnector("文件系统"(,但我得到了异常:在类路径中找不到实现DynamicTableFactory的标识符"filesystem"的任何工厂。

谢谢:(

您是否在类路径中添加了以下依赖项

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-files</artifactId>
<version>${flink.version}</version>
</dependency>

相关内容

  • 没有找到相关文章

最新更新