官术网_书友最值得收藏!

1.4.3 Flink常用命令

Flink以CLI的方式提供了一些常見的操作任務。下面是常用的CLI命令。

(1)查看正在運行的作業(yè),有兩種方式。

第1種,CLI方式,命令如下:

第2種,可用REST API方式查看正在運行的作業(yè),命令如下:

(2)運行示例程序,不帶參數(shù),命令如下:

(3)運行示例程序,帶有input和output參數(shù),命令如下:

(4)運行示例程序,帶有input和output參數(shù),并且將并行度指定為16,命令如下:

(5)運行示例程序,禁用Flink日志輸出,命令如下:

(6)運行示例程序,在分離模式(Detached Mode)下,命令如下:

(7)運行示例程序,在特定的JobManager上,命令如下:

(8)運行示例程序,以特定的類作為入口點,命令如下:

(9)運行示例程序,使用帶有兩個TaskManager的一個Per-Job YARN集群,命令如下:

(10)以JSON格式顯示W(wǎng)ordCount示例程序的優(yōu)化執(zhí)行計劃,命令如下:

(11)列出已調度和正在運行的作業(yè)(包括它們的JobIDs),命令如下:

(12)列出已調度的作業(yè)(包括它們的JobIDs),命令如下:

(13)列出正在運行的作業(yè)(包括它們的JobIDs),命令如下:

(14)列出所有現(xiàn)有的作業(yè)(包括它們的JobIDs),命令如下:

(15)列出在Flink YARN session內正在運行的Flink作業(yè),命令如下:

(16)取消一個作業(yè),命令如下:

(17)取消一個作業(yè),帶有savepoint,命令如下:

(18)停止一個作業(yè)(僅限于流作業(yè)),命令如下:

(19)修改一個正在運行的作業(yè)(僅限于流作業(yè)),命令如下:

主站蜘蛛池模板: 遵化市| 通海县| 绥滨县| 抚顺市| 河津市| 四会市| 泽州县| 三穗县| 中牟县| 响水县| 白水县| 阿瓦提县| 正定县| 甘肃省| 湟源县| 台州市| 阿拉尔市| 潼南县| 咸宁市| 崇信县| 安乡县| 碌曲县| 太仆寺旗| 东至县| 五指山市| 沙坪坝区| 军事| 宽城| 桐柏县| 浦县| 年辖:市辖区| 塔城市| 封丘县| 呼伦贝尔市| 治多县| 类乌齐县| 永嘉县| 宜春市| 吉安市| 霍城县| 崇左市|