Exception in thread “main“ java.lang.NoClassDefFoundError: org/apache/flink/

问题描述

Idea 运行 Flink job 的 main 方法的时候，提示错误如下：

Error: A JNI error has occurred, please check your installation and try again
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/api/common/serialization/DeserializationSchema
	at java.lang.Class.getDeclaredMethods0(Native Method)
	at java.lang.Class.privateGetDeclaredMethods(Class.java:2701)
	at java.lang.Class.privateGetMethodRecursive(Class.java:3048)
	at java.lang.Class.getMethod0(Class.java:3018)
	at java.lang.Class.getMethod(Class.java:1784)
	at sun.launcher.LauncherHelper.validateMainClass(LauncherHelper.java:650)
	at sun.launcher.LauncherHelper.checkAndLoadMain(LauncherHelper.java:632)
Caused by: java.lang.ClassNotFoundException: org.apache.flink.api.common.serialization.DeserializationSchema
	at java.net.URLClassLoader.findClass(URLClassLoader.java:387)
	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)
1
2
3
4
5
6
7
8
9
10
11
12
13
14

类似地 org/apache/flink/stream … 等等。

问题分析

写代码的时候并没有提示错误，而是在运行的时候提示缺包，需要找到对应的 pom 依赖包，加入 pom 文件中，并且一定要注意 Flink 的版本问题，flink-core, flink-stream, flink-java 等。

另外还有 pom 依赖需要指定如果是 provided 极有可能出现上面的问题。

解决方法

1. 确保添加了依赖

检查自己是否添加这个依赖包。以上面的情况为例，org/apache/flink/api/common ，对应的是 flink-core，因此添加依赖如下：

一定要注意 flink 的版本问题，这个是使用前面定义好的 flink.version(1.12.1)


<dependency>
   <groupId>org.apache.flinkgroupId>
   <artifactId>flink-coreartifactId>
   <version>${flink.version}version>
   <scope>providedscope>
dependency>
1
2
3
4
5
6
7