对Flink的Beam管道部署失败了404

问题描述 投票:1回答:1

我正在尝试在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

我究竟做错了什么?

apache-flink apache-beam
1个回答
1
投票

请将你的Flink降级到1.5.0,一切都应该有效。在REST API中,您将找到blobserver/port

© www.soinside.com 2019 - 2024. All rights reserved.