Ошибка выполнения задания Flink при запуске - PullRequest
1 голос
/ 07 марта 2019

Я пытаюсь запустить примеры обработчиков данных, доступные на github. Я прочитал учебник и добавил необходимые SDK и загрузил файлы для NYCFares and Rides. Всякий раз, когда я запускаю пример RideCount.java, я получаю Сбой при выполнении задания. Вот ссылка на git-репо для файла класса RideCount. Github репо RideCount.java

вот ошибка enter image description here

1 Ответ

1 голос
/ 07 марта 2019

Похоже, что файл 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, но некоторые браузеры могут создавать проблемы.

...