flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yaoting Gong <fall.for.you....@gmail.com>
Subject Re: java.lang.NoClassDefFoundError: org/apache/flink/table/api/TableEnvironment
Date Tue, 16 Apr 2019 01:54:48 GMT
@Bial Liu  正解。
默认情况下,lib下只有最常用的几个jar. 满足最基础的Stream/Batch 编程。其他比如table,
cep, ml
等都需要在opt/下找到对应的jar,移到lib/中。或者 自己项目里面编译带上也行

On Mon, Apr 15, 2019 at 5:36 PM Biao Liu <mmyy1110@gmail.com> wrote:

> 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