TableAPI找不到类错误org/apache/flink/table/api/TableEnvironment$

来源:6-4 使用Scala完成Table API&SQL功能的开发

人唯优2018

2019-08-04

执行代码:

    val env = ExecutionEnvironment.getExecutionEnvironment
    //拿到Table API执行的上下文环境 tableEnv
    val tableEnv = TableEnvironment.getTableEnvironment(env)
    val path = "D:\\flink-test\\people.csv"
    val data = env.readCsvFile[Person](path,ignoreFirstLine = true)
    data.print()

找不到类错误:

Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/table/api/TableEnvironment$
	at com.szmg.flink.scala.dataset.FlinkTableApp$.main(FlinkTableApp.scala:11)
	at com.szmg.flink.scala.dataset.FlinkTableApp.main(FlinkTableApp.scala)
Caused by: java.lang.ClassNotFoundException: org.apache.flink.table.api.TableEnvironment$
	at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
	at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
	at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
	at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
	... 2 more

pom里面已经引入了相关的依赖:

    <!-- https://mvnrepository.com/artifact/org.apache.flink/flink-table -->
    <dependency>
      <groupId>org.apache.flink</groupId>
      <artifactId>flink-table_2.11</artifactId>
      <version>1.7.0</version>
      <scope>provided</scope>
    </dependency>
写回答

1回答

Michael_PK

2019-08-04

pom中确认下是否真正下载全了。

1
2
Michael_PK
回复
人唯优2018
provide是直接编译时,不管执行的,随意你编译OK但是运行不了
2019-08-05
共2条回复

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势,多语言系统化讲解,极速入门Flink

969 学习 · 296 问题

查看课程