Я пытаюсь запустить простой конвейер Apache Beam на образе Flink 1.5.2 .Когда я запускаю основной класс для развертывания конвейера, я получаю странную ошибку 404.Конвейер работает нормально в облачном потоке данных Google.
Я запускаю основной с параметрами --runner=FlinkRunner, --flinkMaster=localhost:8081 и вижу панель управления Flink на http://localhost:8081.Развертывание завершается неудачно с:
Unrecognised token 'failure': was expecting ('true', 'false' or 'null)
, и, похоже, он пытается получить доступ к localhost:8081/blobserver/port на основе результатов отладки - я могу подтвердить, что этот путь возвращает 404, когда я делаюполучить запрос к нему.
У меня возникает похожая проблема, когда я пытаюсь развернуть задание в виде толстого баночка из веб-интерфейса.RestException в JarPlanHandler.
Я пробовал версии 1.6.0 и 1.5.x - в частности, я использую https://github.com/apache/flink/blob/master/flink-contrib/docker-flink/docker-compose.yml вот так:
FLINK_DOCKER_IMAGE_NAME=flink:1.5.0 docker-compose up
Что я делаю не так?