Flink table api filesystem connector is not available

Question

I'm trying to write to my local filesystem with flink table api (1.15.1 version). I'm using TableDescriptor.forConnector('filesystem') but I get the exception: Could not find any factory for identifier 'filesystem' that implements DynamicTableFactory in the class path.

Thanks:)

Answer 1

Have you added below dependency in your class-path

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