0

嗨，我的 Flink 朋友们，

我在执行我的第一个 Apache Flink 作业时遇到了几个问题。我完成了这个“1-handsOn-Tutorial”的所有步骤： https ://dataartisans.github.io/flink-training/dataStream/1-handsOn.html

我使用IntelliJ（最后我使用了示例解决方案“RideCleansing.java”），通过Maven成功构建了 JAR（mvn clean package），下载了示例数据并启动了 Flink（./bin/start-local.bat） .

我尝试了 2 种方式来启动 Flink 程序：

  1. 从命令行

./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_HOME 指的是 C:\Program Files\Java\jdk1.8.0_131 。你的意思是这里有问题吗？

  1. 从 Web Dashboard 我上传了“提交新作业”面板下的 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 课程？

4

0 回答 0