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中确认下是否真正下载全了。
122019-08-05
相似问题