开发者社区 问答 正文

beam管道部署到Flink失败了404

我正在尝试在Flink 1.5.2 docker镜像上运行一个简单的Apache Beam管道。当我运行主类来部署管道时,我得到了一个奇怪的404错误。该管道在Google Cloud Dataflow上运行良好。

我用参数运行main --runner=FlinkRunner, --flinkMaster=localhost:8081,我可以看到Flink仪表板http://localhost:8081。部署失败:

Unrecognised token 'failure': was expecting ('true', 'false' or 'null)

并且它似乎一直在尝试localhost:8081/blobserver/port基于调试输出进行访问- 我可以确认此路径在我向它发出get请求时返回404。

当我尝试从Web UI部署作为fat 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小助手 2018-12-10 13:04:49 2175 分享 版权
1 条回答
写回答
取消 提交回答
  • flink小助手会定期更新直播回顾等资料和文章干货,还整合了大家在钉群提出的有关flink的问题及回答。

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

    2019-07-17 23:19:10
    赞同 展开评论