flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Biao Liu <mmyy1...@gmail.com>
Subject Re: java.lang.NoClassDefFoundError: org/apache/flink/table/api/TableEnvironment
Date Mon, 15 Apr 2019 09:35:46 GMT
Hi,
猜测是因为 flink-dist.jar 中未包含 table 相关 jar,opt/ 下应该有
flink-table-xxx.jar,带上这个包再运行试试 (可以先粗暴点把这个包放到
lib/ 下再运行)

Han Mingcong <hanmingcong123@hotmail.com> 于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>
>
> 请问如何解决这个问题?
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message