Hi, 猜测是因为 flink-dist.jar 中未包含 table 相关 jar，opt/ 下应该有 flink-table-xxx.jar，带上这个包再运行试试 (可以先粗暴点把这个包放到 lib/ 下再运行)
Han Mingcong <[email protected]> 于2019年4月15日周一 下午5:05写道： > 您好， > 近期在调研Flink，从官网下载的flink-1.7.2-bin-hadoop28-scala_2.11版本，在使用flink run > 提交一个Table作业时有以下报错： > > [bin]$ ./flink run -c WordCountTable ../../WC.jar > Starting execution of program > java.lang.NoClassDefFoundError: org/apache/flink/table/api/TableEnvironment > at WordCountTable.main(WordCountTable.java:22) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > at java.lang.reflect.Method.invoke(Method.java:498) > at > org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:529) > at > org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:421) > at > org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:427) > at > org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:813) > at org.apache.flink.client.cli.CliFrontend.runProgram(CliFrontend.java:287) > at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:213) > at > org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1050) > at > org.apache.flink.client.cli.CliFrontend.lambda$main$11(CliFrontend.java:1126) > at java.security.AccessController.doPrivileged(Native Method) > at javax.security.auth.Subject.doAs(Subject.java:422) > at > org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1836) > at > org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) > at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1126) > Caused by: java.lang.ClassNotFoundException: > org.apache.flink.table.api.TableEnvironment > at java.net.URLClassLoader.findClass(URLClassLoader.java:382) > at java.lang.ClassLoader.loadClass(ClassLoader.java:424) > at java.lang.ClassLoader.loadClass(ClassLoader.java:357) > ... 18 more > > 程序源码来自于 > https://github.com/apache/flink/blob/release-1.7/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/WordCountTable.java > > pom.xml: > > <dependencies> > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-table_2.11</artifactId> > <version>1.7.2</version> > </dependency> > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-streaming-scala_2.11</artifactId> > <version>1.7.2</version> > </dependency> > </dependencies> > > 请问如何解决这个问题？ > >
