2025年yarn查看任务状态（查询yarn上运行的任务）

科技前沿 • 2025-05-09 16:35 • 阅读 40

大家好，我是讯享网，很高兴认识大家。

使用 Flink SQL 客户端以 YARN Application 模式提交任务，可以按照以下步骤进行操作：

准备环境：确保你已经安装了 Flink 和 YARN 的相关组件，并且已经配置好了 Flink 和 YARN 的运行环境。

启动 Flink SQL 客户端：打开终端或命令提示符，并输入以下命令启动 Flink SQL 客户端：

bash
https://developer.aliyun.com/ask/bin/flink-sql-client.sh embedded –jar –class
其中，是你的 Flink 应用程序的 JAR 文件的路径，是你的应用程序的入口类。

配置 YARN 集群信息：在 Flink SQL 客户端启动后，你需要配置 YARN 集群的相关信息。在 SQL 客户端的命令行界面中，输入以下命令：

sql
SET ‘execution.target’=‘yarn’;
SET ‘yarn.application.node-label’=‘’;
SET ‘yarn.application.name’=‘’;
SET ‘yarn.application.queue’=‘’;
其中，是你为 YARN 节点指定的标签，是你的应用程序的名称，是你希望提交应用程序的 YARN 队列名称。

讯享网

编写和提交 Flink SQL 查询：在配置好 YARN 集群信息之后，你可以编写和提交 Flink SQL 查询。在 SQL 客户端的命令行界面中，输入你的 Flink SQL 查询，并使用 RUN 命令执行查询。例如：

sql
CREATE TABLE my_table (id INT, name STRING) WITH (…) …;
INSERT INTO my_table SELECT * FROM …;
RUN;
等待任务完成：提交查询后，Flink 会自动将任务提交给 YARN 进行调度和执行。你可以等待任务完成，并查看任务的结果。

结束 Flink SQL 客户端会话：当任务完成后，你可以使用以下命令结束 Flink SQL 客户端会话：

sql
SET ‘execution.target’=‘local’;
这将停止将任务提交给 YARN，并将执行模式设置为本地模式。然后，你可以输入 EXIT; 退出 Flink SQL 客户端。

这样，你就成功地使用 Flink SQL 客户端以 YARN Application 模式提交了任务。请确保根据你的实际情况修改相关配置和查询语句。

2025年yarn查看任务状态（查询yarn上运行的任务）

相关推荐