Flink报错Create BatchTableEnvironment failed

Flink DataSet Table相互之间转换报错

Exception in thread "main" org.apache.flink.table.api.TableException: Create BatchTableEnvironment failed.
	at org.apache.flink.table.api.scala.BatchTableEnvironment$.create(BatchTableEnvironment.scala:308)
	at org.apache.flink.table.api.scala.BatchTableEnvironment$.create(BatchTableEnvironment.scala:269)
	at FlinkTest$.main(FlinkTest.scala:151)
	at FlinkTest.main(FlinkTest.scala)
Caused by: java.lang.ClassNotFoundException: org.apache.flink.table.api.scala.internal.BatchTableEnvironmentImpl
	at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
	at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
	at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:338)
	at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
	at java.lang.Class.forName0(Native Method)
	at java.lang.Class.forName(Class.java:264)
	at org.apache.flink.table.api.scala.BatchTableEnvironment$.create(BatchTableEnvironment.scala:292)
	... 3 more
复制代码

报错代码

// 获取flink环境
val flink = ExecutionEnvironment.getExecutionEnvironment
// 批量表环境变量
val tableEnv = BatchTableEnvironment.create(flink)  // 此处报错
复制代码

解决方案

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner_2.11</artifactId>
<version>${flink.version}</version>
</dependency>
复制代码

公众号

微信号：bigdata_limeng