运行flink教程ridecleansing时出现的问题

lmyy7pcs  于 2021-06-25  发布在  Flink
关注(0)|答案(0)|浏览(260)

嗨,我的Flink朋友们,

关于我的第一份apache flink工作的执行,我有几个问题。我完成了“单手教程”的所有步骤:https://dataartisans.github.io/flink-training/datastream/1-handson.html
我与intellij合作(最后使用了示例解决方案“ridecleansing.java”),通过maven成功地构建了jar(mvn clean package),下载了示例数据并启动了flink(./bin/start local.bat)。

我尝试了两种启动flink程序的方法:

从命令行 ./bin/flink run -c com.dataartisans.flinktraining.exercises.datastream_java.basics.RideCleansing /path/flink-training-exercises/target/flink-training-exercises-0.5.jar --input file:///Users/full_user_name/Downloads/nycTaxiRides.gz 但出现以下错误:

./bin/flink: line 55: C:\Program: No such file or directory

所以我认为“程序文件”之间的空白有一些问题。。。我的java\u主页是指c:\program files\java\jdk1.8.0\u 131。你说这里哪里不对?
我从web Jmeter 板上传了“submitnewjob”面板下的flink-training-exercises-0.5.jar,引用了主类和示例数据。
在这种情况下,程序会进一步运行,但会以异常结束:

Caused by: java.lang.ClassNotFoundException:      
    org.joda.time.format.DateTimeFormatter
    at java.net.URLClassLoader.findClass(Unknown Source)
    at java.lang.ClassLoader.loadClass(Unknown Source)
    at java.lang.ClassLoader.loadClass(Unknown Source)
    ... 58 more

你能告诉我出什么事了吗?这里发生了什么事?我忘了一些步骤吗?为什么找不到这个joda类?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题