关闭 flink yarn sessioncli 的流程如下表所示:
步骤 | 操作 |
---|---|
1 | 连接到 flink yarn sessioncli |
2 | 获取正在运行的 flink yarn sessioncli 的应用ID |
3 | 停止 flink yarn sessioncli 的应用 |
4 | 检查 flink yarn sessioncli 的应用状态 |
5 | 关闭 flink yarn sessioncli |
下面是每个步骤的具体操作和相应的代码注释:
步骤 1:连接到 flink yarn sessioncli
首先,我们需要连接到 flink yarn sessioncli。可以使用以下代码:
flink-yarn-session.sh -n 2 -jm 1024m -tm 2048m
-n 2
指定启动两个 TaskManager 节点-jm 1024m
指定 JobManager 内存为 1024MB-tm 2048m
指定 TaskManager 内存为 2048MB
步骤 2:获取正在运行的 flink yarn sessioncli 的应用ID
运行以下命令获取正在运行的 flink yarn sessioncli 的应用ID:
yarn application -list
找到 flink yarn sessioncli 的应用ID,并记住它。例如,应用ID 为 app_1234567890_1234。
步骤 3:停止 flink yarn sessioncli 的应用
使用以下命令停止 flink yarn sessioncli 的应用:
yarn application -kill <app_id>
将 <app_id>
替换为在步骤 2 中获取到的应用ID。例如,如果应用ID 为 app_1234567890_1234,则命令如下:
yarn application -kill app_1234567890_1234
步骤 4:检查 flink yarn sessioncli 的应用状态
可以使用以下命令检查 flink yarn sessioncli 的应用状态:
yarn application -status <app_id>
将 <app_id>
替换为在步骤 2 中获取到的应用ID。例如,如果应用ID 为 app_1234567890_1234,则命令如下:
yarn application -status app_1234567890_1234
该命令将显示应用的状态,例如 FINISHED
、RUNNING
或 FAILED
。
步骤 5:关闭 flink yarn sessioncli
如果应用状态为 FINISHED
,则表示 flink yarn sessioncli 已成功关闭。如果应用状态为 RUNNING
或 FAILED
,则可以尝试再次停止应用或联系管理员进行进一步处理。
以上是关闭 flink yarn sessioncli 的流程和相应的代码注释。希望能帮助到你!