代码之家 › 专栏 › 技术社区 › brabster

束流管道部署到Flink失败,404

apache-beam apache-flink

brabster · 技术社区 · 6 年前

我试着在一个平台上运行一个简单的apachebeam管道 Flink 1.5.2 docker image . 当我运行main类来部署管道时,我得到了一个奇怪的404错误。管道在Google云数据流上运行良好。

我用参数运行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。

当我尝试从webui将作业部署为胖jar时,我也遇到了类似的问题。JarPlanHandler中的RestException。

FLINK_DOCKER_IMAGE_NAME=flink:1.5.0 docker-compose up

我做错什么了?

1 回复 | 直到 6 年前

klocek 6 年前

请把你的Flink降到1.5.0,一切正常。在restapi中可以找到 blobserver/port

推荐文章

Philipp · 使用python的apache beam中PCollection内几个字段的最大值和最小值

6 年前

Jaison · 是否可以使用Apache beam处理非结构化数据(多行web日志)?

6 年前

smanurung · 使用ValueProvider读取多个Pubsub订阅

6 年前

Josh Sacks · 控制数据流/Apache Beam输出分片

6 年前

bw4sz · 除了google云数据流之外,apache beam python还支持哪些跑步者?

6 年前

Nagesh Singh Chauhan · 无法将beamSql数据写入BigQuery

6 年前

Nagesh Singh Chauhan · 如何在BeamSql中将BeamRecord转换为字符串

6 年前

Jermell Beane · 使用标签选项时,模板无法在GoogleCloudDataflow上解析

6 年前

Zach Moshe · 从自定义DoFn生成“finish\u bundle”结果

6 年前

Tamas Eppel · 使用Apache Beam在导入和全局数据库中查找重复项

6 年前