学习 Flink(十四):REST API

更新至 Flink 1.8 版本

Flink 为 Web 仪表盘提供了 REST API,同时,我们也可以调用该 REST API 实现应用的部署和监控等功能。

默认,REST API 服务监听 8081 端口,编辑 conf/flink-conf.yml 文件,修改 rest.port 配置:

rest.port: 8421  

示例

任务概览

curl -X GET http://JM_SERVER/v1/jobs/overview  

任务指标

在任务概览中可以查询到任务 ID,使用任务 ID 查询任务指标。

支持的指标:

curl -X GET http://JM_SERVER/v1/jobs/<任务 ID>/metrics  

任务运行时长(uptime 指标):

curl -X GET http://JM_SERVER/v1/jobs/<任务 ID>/metrics?get=uptime  

上传 JAR

curl -X POST -H "Expect:" -F "jarfile=@/home/flink/app.jar" http://JM_SERVER/v1/jars/upload  

参考