org.apache.flink.api.scala.typeutils.CaseClassTypeInfo_caused by: java.lang.classnotfoundexception: org.a

本地运行Flink程序出现error如下

Caused by: java.lang.ClassNotFoundException: org.apache.flink.api.scala.typeutils.CaseClassTypeInfo
	at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
	at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
	at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349)
	at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
	... 1 more
1
2
3
4
5
6

本以为是导包问题

import org.apache.flink.streaming.api.scala._
1

排查一会发现是maven引入依赖问题

解决方案是去掉scope，正确的依赖如下，问题解决！

<dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-streaming-scala_2.11</artifactId>
            <version>1.6.1</version>
            <!--<scope>provided</scope>-->
</dependency>
1
2
3
4
5
6