哪位好汉在用flink 1.16.2提交任务的时候用yarn-application模式提交任务?![阿里云实时计算 Flink版] 暂停朗读为您朗读

在 Flink 1.16.2 中，可以使用 Yarn Application 模式来提交 Flink 任务。下面是使用 Yarn Application 模式提交 Flink 任务的步骤：

编写 Flink 任务代码，并将其打包成 jar 包。

将 Flink 的 bin 目录添加到系统的 PATH 环境变量中。

使用 flink run-application 命令提交 Flink 任务，例如：

haml
Copy
flink run-application
–target yarn-application
–detached
–name my-flink-job
–classpath file:///path/to/my-job.jar
–yarnconfiguration yarn-site.xml
–yarnqueue my-queue
–yarnslots 4
–yarnjobmanagermemory 1024m
–yarntaskmanagermemory 2048m
–yarnapplicationType ApacheFlink
–args “–input input.txt –output output.txt”
在这个命令中，–target 参数指定为 yarn-application，–classpath 参数指定为打包后的 jar 包路径，–yarnconfiguration 参数指定为 Yarn 的配置文件（例如 yarn-site.xml），–yarnqueue 参数指定为提交任务的队列名称，–yarnslots 参数指定为任务的并行度，–yarnjobmanagermemory 参数指定为 JobManager 的内存大小，–yarntaskmanagermemory 参数指定为 TaskManager 的内存大小，–yarnapplicationType 参数指定为 ApacheFlink，–args 参数指定为任务的命令行参数。

使用 –detached 参数可以将任务提交到 Yarn 集群后立即返回，并在后台运行。如果不使用 –detached 参数，则任务将会在前台运行，直到任务完成或者被中断。

使用 yarn application -list 命令查看已提交的 Yarn Application，例如：

Copy
yarn application -list
在输出中可以看到已提交的 Yarn Application 信息，包括 Application ID、名称、状态等。