怎么指定 flink yarn-session 启动 这properties 的文件存放位置?不让他存放在 tmp 目录,要改那个配置
要指定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
文件。下面是一个示例命令行:
flink run -m yarn-cluster -yn <numTaskManagers> -yjm <jobManagerMemory> -ys <taskManagerMemory> --job <jobName> --class <jobClassName> --jar <jobJarPath> --configdir <configDir> --yarnapplicationname <yarnApplicationName> --yarnjar <yarnJarPath> -Dyarn.application.status.address <yarnStatusAddress> -Dyarn.application.queue <yarnQueue> -Dyarn.client.failover-check-interval <failoverCheckInterval> -Dyarn.client.retries.file <retryFilePath> -Dyarn.log-aggregation-enable <logAggregationEnable> -Dyarn.log-aggregation-type <logAggregationType> -Dyarn.nodemanager.pmem-check-enabled <pmemCheckEnabled> -Dyarn.nodemanager.vmem-check-enabled <vmemCheckEnabled> -Dyarn.resourcemanager.address <resourceManagerAddress> -Dyarn.resourcemanager.scheduler.address <schedulerAddress> -Dyarn.timeline-service.address <timelineServiceAddress> -Dyarn.webapp.address <webAppAddress>
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。