我正在尝试在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
我究竟做错了什么?
请将你的Flink降级到1.5.0,一切都应该有效。在REST API中,您将找到blobserver/port