我正在尝试使用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>