java - Flink 作业执行运行失败

Question

我正在尝试运行 github 上提供的数据工匠示例。我阅读了教程并添加了所需的 SDK，并下载了 NYCFares 和 Rides 的文件。每当我运行 RideCount.java 示例时，我都会收到“作业执行失败”的消息。以下是 RideCount 类文件的 git 存储库的链接。 Github repo RideCount.java

这是错误

Answer 1

nycTaxiRides.gz 文件似乎已被损坏。屏幕截图中显示的行应包含以下内容

914757,START,2013-01-03 10:00:57,1970-01-01 00:00:00,-73.982796,40.781418,-73.97155,40.761257,1,2013002770,2013017291

解析输入的代码提示并非所有字段都存在。我建议您重新下载数据文件，小心不要解压或以其他方式更改它。 Chrome、wget、curl 都可以做到这一点，但有些浏览器会引入问题。