我正在尝试在flink1.5.2docker映像上运行一个简单的apachebeam管道。当我运行main类来部署管道时,我得到了一个奇怪的404错误。管道在google云数据流上运行良好。
我用参数运行main --runner=FlinkRunner, --flinkMaster=localhost:8081
,我可以看到flink Jmeter 盘 http://localhost:8081
. 部署失败,原因是: Unrecognised token 'failure': was expecting ('true', 'false' or 'null)
它似乎一直在试图进入 localhost:8081/blobserver/port
根据调试输出-我可以确认,当我对该路径执行get请求时,该路径返回404。
当我尝试从webui将作业部署为胖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
我做错什么了?
1条答案
按热度按时间vfhzx4xs1#
请把你的flink降到1.5.0,一切正常。在restapi中可以找到
blobserver/port