我正在尝试在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降级到1.5.0,一切都应该有效。在REST API中,您将找到blobserver/port