tongchenkeji
发表于：0次点击

Flink中通过api的方式来提交flink任务到yarn集群这种提交方式在官网哪里有人知道吗？[阿里云实时计算 Flink版]

通过api的方式来提交flink任务到yarn集群这种提交方式在官网哪里有人知道吗？

「点点赞赏，手留余香」

    还没有人赞赏，快来当第一个赞赏的人吧！
实时计算Flink版# API1163# 实时计算 Flink版3179# 流计算2236# 资源调度143
=====这是一个广告位，招租中，联系qq 78315851====
实时计算Flink版
请教一个flink的问题，我程序运行这偶尔就会报这个错，能帮忙解决一下这个问题吗？[阿里云实时计算 Flink版]
实时计算Flink版
Apache Flink China读hive报这个，该怎么解决？[阿里云实时计算 Flink版]
1 条回复 A 作者 M 管理员

  1. 如果您想在阿里云实时计算 Flink版中，通过 API 的方式提交 Flink 任务到 YARN 集群，请按照以下步骤操作：

    1. 确认您已经在阿里云实时计算 Flink版中创建了 YARN 集群和 Flink 集群，并且这两个集群已经正确地配置和启动。

    2. 使用 Flink REST API 提交作业，可以通过以下命令：

    curl -XPOST http://:8081//jars/?entry-class=&program-args=&savepoint-path=&allowNonRestoredState=

    其中：

    • 是 Flink REST Server 的地址;
    • 是要提交的程序包的 ID;
    • 是程序包的主类;
    • 是要传递给程序包的参数;
    • 是可选的，表示要恢复作业的保存点路径；如果省略，则表示不进行保存点恢复；
    • 是可选的，表示是否允许非恢复状态的提交（即初始状态），默认为 false。

    需要注意的是，您需要对命令中的参数进行相应的替换，其中 和 需要根据您自己的环境来指定。

    1. 如果您需要在 Flink 应用中使用 YARN 的资源管理器，请确保您已正确配置 YARN 环境，并在应用程序中进行相关配置。具体方式请参考 Flink 官方文档。
    已喜欢 已反对

  2. Flink 提交到 YARN 集群的方式主要有两种，一种是通过命令行工具 flink-yarn.sh 进行提交，另一种是通过 Flink 的 Java API 进行提交。

    关于通过 Java API 提交 Flink 任务到 YARN 集群的方式，你可以在 Flink 官方文档中找到详细的说明。具体而言，可以查看以下文档：

    Submitting Applications on YARN：该文档介绍了如何使用 Flink 的 Java API 在 YARN 上提交应用程序，并提供了详细的示例代码。 YARN Client：该文档介绍了如何使用 Flink YARN client 类库来构建和配置 Flink 应用程序，并通过 Java API 将其提交到 YARN 集群中运行。 在这些文档中，你可以了解到如何使用 YarnClusterDescriptor 和 YarnClientFactory 类来构建 Flink 应用程序，并如何设置应用程序的运行参数、资源需求等信息。此外，还会介绍如何将应用程序打包成可执行的 jar 包，并将其提交到 YARN 集群中运行。

    已喜欢 已反对