MAPREDUCE服务 MRS-Flink作业参数规则:Flink作业参数配置规范
Flink作业参数配置规范
Flink作业参数配置规范如下表所示。
参数名称 |
是否必填 |
参数描述 |
建议值 |
---|---|---|---|
-c |
必填 |
指定主类名。 |
根据实际情况而定 |
-ynm |
必填 |
Flink Yarn作业名称。 |
根据实际情况而定 |
execution.checkpointing.interval |
必填 |
Checkpoint触发间隔(毫秒),通过-yD添加,单位毫秒。 |
60000 |
execution.checkpointing.timeout |
必填 |
Checkpoint超时时长,通过-yD添加,默认值为30min。 |
30min |
parallelism.default |
选填 |
作业并行度,例如join算子,通过-yD添加,默认值为1。 |
根据实际情况而定 |
table.exec.state.ttl |
必填 |
Flink状态ttl(join ttl),通过-yD添加,默认值为0。 |
根据实际情况而定 |
- MapReduce服务_什么是Flink_如何使用Flink
- 数据治理中心_数据开发_数据开发示例_使用教程-华为云
- ModelArts模型训练_创建训练作业_如何创建训练作业
- MapReduce服务_什么是存算分离_如何配置MRS集群存算分离
- 什么是Flink OpenSource SQL_数据湖探索_Flink OpenSource SQL
- MapReduce服务_什么是Loader_如何使用Loader
- MapReduce工作原理_MapReduce是什么意思_MapReduce流程_MRS_华为云
- MapReduce服务_什么是Kafka_如何使用Kafka
- Hudi服务_什么是Hudi_如何使用Hudi
- MapReduce服务_如何使用MapReduce服务_MRS集群客户端安装与使用