我正在尝试在 Flink 1.5.2 docker 镜像上运行一个简单的 Apache Beam 管道。当我运行主类来部署管道时，我收到一个奇怪的 404 错误。该管道在Google Cloud Dataflow上运行良好。
我用参数--runner=FlinkRunner, --flinkMaster=localhost:8081运行主，我可以在http://localhost:8081上看到 Flink 仪表板。部署失败，并显示：
Unrecognised token 'failure': was expecting ('true', 'false' or 'null)
它似乎一直在尝试根据调试输出访问localhost:8081/blobserver/port- 我可以确认这条路径在我向它发出 get 请求时返回 404。
当我尝试从 Web UI 将作业部署为胖罐子时，我遇到了类似的问题。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
我做错了什么？
请将您的 Flink 降级到 1.5.0，一切正常。在 REST API 中，您将找到blobserver/port