一、概述
Apache Flink是一个流处理框架，支持高效的有状态流计算和批处理。Flink Rest API是将客户端与Flink集群进行通信的基本方式之一。该API提供了一组用于查询和管理Flink应用程序的REST终端点。
二、使用方法
使用Flink Rest API可以通过下列步骤进行：
1、设置REST端口：在flink-conf.yaml文件中，设置rest.port参数值为REST服务器应该启动的端口号。
rest.port: 80812、运行REST服务器：运行Flink REST服务器可以使用以下命令：
./bin/start-cluster.sh
./bin/taskmanager.sh start
./bin/rest-server.sh start3、访问REST API：通过Web浏览器或HTTP客户端，使用REST API访问Flink应用程序。
三、REST端点
在Flink Rest API中，以下是最常用的REST端点：
1、Jar上传端点
这个端点允许用户将Jar文件上传到Flink集群。一旦JAR文件上传成功，它将被列出在集群的可用作业列表中，然后可以为它创建一个作业。
POST /jars/upload2、Jar列表端点
这个端点会返回集群上可用的所有JAR文件列表。
GET /jars3、提交作业端点
提交作业是将一个Flink作业提交到集群以运行。一个作业可以通过jarId参数引用一个先前上传的JAR文件。
POST /jars/:jarId/run4、取消作业端点
这个端点可以取消正在运行的特定作业。需要作业ID。
DELETE /jobs/:jobId5、作业状态端点
使用此端点可以获取作业的状态以及度量信息。
GET /jobs/:jobId四、总结
Flink Rest API提供了一组非常简单的REST终端点，旨在使用户更轻松地与Flink集群以及Flink应用程序进行交互。通过访问这些端点，用户可以上传和管理Jar文件，并在Flink集群上提交和取消作业。
原创文章，作者：小蓝，如若转载，请注明出处：https://www.506064.com/n/249112.html
微信扫一扫 
支付宝扫一扫 