Flink Rest API详细介绍

一、概述

Apache Flink是一个流处理框架，支持高效的有状态流计算和批处理。Flink Rest API是将客户端与Flink集群进行通信的基本方式之一。该API提供了一组用于查询和管理Flink应用程序的REST终端点。

二、使用方法

使用Flink Rest API可以通过下列步骤进行：

1、设置REST端口：在flink-conf.yaml文件中，设置rest.port参数值为REST服务器应该启动的端口号。

rest.port: 8081

2、运行REST服务器：运行Flink REST服务器可以使用以下命令：

./bin/start-cluster.sh
./bin/taskmanager.sh start
./bin/rest-server.sh start

3、访问REST API：通过Web浏览器或HTTP客户端，使用REST API访问Flink应用程序。

三、REST端点

在Flink Rest API中，以下是最常用的REST端点：

1、Jar上传端点

这个端点允许用户将Jar文件上传到Flink集群。一旦JAR文件上传成功，它将被列出在集群的可用作业列表中，然后可以为它创建一个作业。

POST /jars/upload

2、Jar列表端点

这个端点会返回集群上可用的所有JAR文件列表。

GET /jars

3、提交作业端点

提交作业是将一个Flink作业提交到集群以运行。一个作业可以通过jarId参数引用一个先前上传的JAR文件。

POST /jars/:jarId/run

4、取消作业端点

这个端点可以取消正在运行的特定作业。需要作业ID。

DELETE /jobs/:jobId

5、作业状态端点

使用此端点可以获取作业的状态以及度量信息。

GET /jobs/:jobId

四、总结

Flink Rest API提供了一组非常简单的REST终端点，旨在使用户更轻松地与Flink集群以及Flink应用程序进行交互。通过访问这些端点，用户可以上传和管理Jar文件，并在Flink集群上提交和取消作业。