tongchenkeji 发表于:2023-12-10 17:34:100次点击 已关注取消关注 关注 私信 怎么指定 flink yarn-session 启动 这properties 的文件存放位置?[阿里云] 暂停朗读为您朗读 怎么指定 flink yarn-session 启动 这properties 的文件存放位置?不让他存放在 tmp 目录,要改那个配置 「点点赞赏,手留余香」 赞赏 还没有人赞赏,快来当第一个赞赏的人吧! 海报 阿里云# 实时计算 Flink版3179# 流计算2236
小周sirAM 2023-12-21 8:09:15 2 要指定Flink Yarn Session启动的properties文件存放位置,可以通过以下步骤进行操作: 创建一个包含所需配置的properties文件,例如flink-yarn-session.properties。 将该properties文件放置在Flink安装目录的conf文件夹中。 在启动Flink Yarn Session时,通过命令行参数--yarnapplicationname指定Yarn应用程序的名称,并通过命令行参数--yarnjar指定Flink作业的JAR包路径。 使用-Dyarn.application.status.address参数指定Yarn Application Master的状态地址。 使用-Dyarn.application.queue参数指定Yarn队列名称。 使用-Dyarn.client.failover-check-interval参数指定Yarn客户端故障恢复检查的时间间隔。 使用-Dyarn.client.retries.file参数指定Yarn客户端重试文件的路径。 使用-Dyarn.log-aggregation-enable参数启用Yarn日志聚合功能。 使用-Dyarn.log-aggregation-type参数指定Yarn日志聚合的类型。 使用-Dyarn.nodemanager.pmem-check-enabled参数启用Yarn NodeManager的PMEM内存检查功能。 使用-Dyarn.nodemanager.vmem-check-enabled参数启用Yarn NodeManager的VMEM虚拟内存检查功能。 使用-Dyarn.resourcemanager.address参数指定Yarn ResourceManager的地址。 使用-Dyarn.resourcemanager.scheduler.address参数指定Yarn调度器的地址。 使用-Dyarn.timeline-service.address参数指定Yarn时间线的地址。 使用-Dyarn.webapp.address参数指定Yarn Web界面的地址。 使用--configdir参数指定Flink配置文件的目录,该目录应包含之前创建的flink-yarn-session.properties文件。 下面是一个示例命令行: flink run -m yarn-cluster -yn -yjm -ys --job --class --jar --configdir --yarnapplicationname --yarnjar -Dyarn.application.status.address -Dyarn.application.queue -Dyarn.client.failover-check-interval -Dyarn.client.retries.file -Dyarn.log-aggregation-enable -Dyarn.log-aggregation-type -Dyarn.nodemanager.pmem-check-enabled -Dyarn.nodemanager.vmem-check-enabled -Dyarn.resourcemanager.address -Dyarn.resourcemanager.scheduler.address -Dyarn.timeline-service.address -Dyarn.webapp.address
-path xx.properties ,此回答整理自钉群“【③群】Apache Flink China社区”
要指定Flink Yarn Session启动的properties文件存放位置,可以通过以下步骤进行操作:
flink-yarn-session.properties
。conf
文件夹中。--yarnapplicationname
指定Yarn应用程序的名称,并通过命令行参数--yarnjar
指定Flink作业的JAR包路径。-Dyarn.application.status.address
参数指定Yarn Application Master的状态地址。-Dyarn.application.queue
参数指定Yarn队列名称。-Dyarn.client.failover-check-interval
参数指定Yarn客户端故障恢复检查的时间间隔。-Dyarn.client.retries.file
参数指定Yarn客户端重试文件的路径。-Dyarn.log-aggregation-enable
参数启用Yarn日志聚合功能。-Dyarn.log-aggregation-type
参数指定Yarn日志聚合的类型。-Dyarn.nodemanager.pmem-check-enabled
参数启用Yarn NodeManager的PMEM内存检查功能。-Dyarn.nodemanager.vmem-check-enabled
参数启用Yarn NodeManager的VMEM虚拟内存检查功能。-Dyarn.resourcemanager.address
参数指定Yarn ResourceManager的地址。-Dyarn.resourcemanager.scheduler.address
参数指定Yarn调度器的地址。-Dyarn.timeline-service.address
参数指定Yarn时间线的地址。-Dyarn.webapp.address
参数指定Yarn Web界面的地址。--configdir
参数指定Flink配置文件的目录,该目录应包含之前创建的flink-yarn-session.properties
文件。下面是一个示例命令行: