看了一天，能不能本地写一个完整的job，打jar包，提交flink上，写入ES的

Question

老师，能不能写一个这个文档，我急需这个文档示例，我们的数据是从kafka拿到的json数据，如何进行转换呢？麻烦老师写一个示例代码，急救谢谢

Answer 1

提问者 yhy1271927580 2019-04-11 22:21:47

yinhuanyideMacBook-Pro:target yinhuanyi$ java -jar flink-quick-1.0-SNAPSHOT.jar

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/functions/FlatMapFunction

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:544)

at sun.launcher.LauncherHelper.checkAndLoadMain(LauncherHelper.java:526)

Caused by: java.lang.ClassNotFoundException: org.apache.flink.api.common.functions.FlatMapFunction

at java.net.URLClassLoader.findClass(URLClassLoader.java:382)

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)

... 7 more

• 提问者 yhy1271927580 #1

  mvn clean package，打出jar包，出现这个错误

• Michael_PK #2

  Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/api/common/functions/FlatMapFunction
  
  
  
  没找到类

• 提问者 yhy1271927580 #3

  但是这个flink是安装了的，为什么找不到呢？

Answer 2

提问者 yhy1271927580 2019-04-11 12:19:58

我打包的时候有问题，刚刚接触这块，希望老师给一个手动打包发布的视频案例

• Michael_PK #1

  打包就是命令： mvn clean package就打出来了

Answer 3

Michael_PK 2019-04-11 01:50:03

对接到kafka的JSON后，就是解析JSON数据就行了

Answer 4

Michael_PK 2019-04-11 01:48:07

本地开发完打成一个jar包，然后使用flink命令提交就OK了，演示的是官方的jar，没有区别啊

• 慕侠2434193 #1

  也就是说我本地基于springboot开发一个flink项目打成jar包直接提交到flink集群里面就可以了是这样吗？

• Michael_PK 回复 慕侠2434193 #2

  为什么要把flink和boot整合？boot是Javaweb相关的东西。我们是不允许这么使用

• 慕侠2434193 回复 Michael_PK #3

  嗯嗯，我开始理解错了，我以为是用springboot去连接flink然后完成操作。。。今天用flink把单位的kafka和ES都接上了，单位的kafka和es都要认证连起来还挺麻烦。继续学习课程，谢谢老师！