问题:

 原因:

 在类路径中找不到标识符‘ csv’的格式工厂

解决方法:

在Maven工程中的pom.xml文件添加以下依赖

代码如下:

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

 


举一反三:

如果你的报错信息是

在类路径中找不到标识符‘ jdbc’的格式工厂

或者

在类路径中找不到标识符‘ json’的格式工厂 

 则添加以下依赖

jdbc:

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

json:

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

Logo

一站式 AI 云服务平台

更多推荐