一、概述
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/zh-hant/n/249112.html
微信掃一掃 
支付寶掃一掃 