apache-flinkflink-streamingflink-sqlflink-batchflink-table-api

Flink table api filesystem connector is not available

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:)

Solution

  • 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>