【发布时间】:2018-09-14 09:27:33
【问题描述】:
我正在尝试在 Flink 1.5.2 docker image 上运行一个简单的 Apache Beam 管道。当我运行主类来部署管道时,我收到了一个奇怪的 404 错误。该管道在 Google Cloud Dataflow 上运行良好。
我使用参数 --runner=FlinkRunner, --flinkMaster=localhost:8081 运行 main,我可以在 http://localhost:8081 上看到 Flink 仪表板。部署失败:
Unrecognised token 'failure': was expecting ('true', 'false' or 'null)
根据调试输出,它似乎一直在尝试访问 localhost:8081/blobserver/port - 我可以确认当我向它发出 get 请求时此路径返回 404。
当我尝试从 Web UI 将作业部署为胖 jar 时,我遇到了类似的问题。 JarPlanHandler 中的 RestException。
我已经尝试过 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
我做错了什么?
【问题讨论】:
-
同样的问题 :) 如果你能找到新的东西,请告诉我。
-
很高兴知道这不仅仅是我 - 我开始质疑我的理智!