Не удается запустить пример работы Apache Flink с сообщением «Задание не найдено» - PullRequest
Новая
       36

Не удается запустить пример работы Apache Flink с сообщением «Задание не найдено»

0 голосов
/ 10 июля 2019

Попытка запустить пример учебного пособия SocketWindowWordCount, найденного на сайте flink здесь .

Я запустил кластер flink, затем запустил локальный сервер сокетов: 

nc -l 9000

После компиляции исходного кода, взятого из github , я запускаю задание 

flink run target/SocketWindowWordCount.jar  --port 9000

Затем я ввожу несколько слов в терминал, работающий nc. Ничто не идет к ожидаемому выходному файлу, и журнал повторяет эту ошибку: 

2019-07-09 15:54:32,673 ERROR org.apache.flink.runtime.rest.handler.job.JobDetailsHandler   - Exception occurred in REST handler: Job f9b3c58ca3026855fd2612e3c86551fa not found
2019-07-09 15:54:35,673 ERROR org.apache.flink.runtime.rest.handler.job.JobDetailsHandler   - Exception occurred in REST handler: Job f9b3c58ca3026855fd2612e3c86551fa not found
2019-07-09 15:54:38,673 ERROR org.apache.flink.runtime.rest.handler.job.JobDetailsHandler   - Exception occurred in REST handler: Job f9b3c58ca3026855fd2612e3c86551fa not found
2019-07-09 15:54:39,769 ERROR org.apache.flink.runtime.rest.handler.job.JobDetailsHandler   - Exception occurred in REST handler: Job f9b3c58ca3026855fd2612e3c86551fa not found

1 Ответ

1 голос
/ 10 июля 2019

Это обычно происходит, когда у вас в браузере открыта вкладка Flink UI, которая остается открытой после предыдущих развертываний заданий. Таким образом, пользовательский интерфейс указывает на URL с http: //.../f9b3c58ca3026855fd2612e3c86551fa, который представляет собой JobID, который не существует. Это вызывает показ вышеупомянутого журнала.

...