问题一:ClassNotFoundException: org.apache.flink.calcite.shaded.com.google.common.base.Preconditions
Caused by: java.lang.ClassNotFoundException: org.apache.flink.calcite.shaded.com.google.common.base.Preconditions
at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
at java.lang.ClassLoader.loadClass(ClassLoader.java:418)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:355)
at java.lang.ClassLoader.loadClass(ClassLoader.java:351)
... 7 more
解决:缺依赖maven?仓库
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner_2.11</artifactId>
<version>1.12.0</version>
<scope>provided</scope>
</dependency>
问题二:IllegalArgumentException: Primary keys not defined in the sink `TableSchema`.
主键的问题
TableSchema.builder().primaryKey(name, new String[]{""})
|