MAPREDUCE服务 MRS-单表并发控制配置
单表并发控制配置
参数 |
描述 |
默认值 |
---|---|---|
hoodie.write.lock.provider |
指定lock provider,不建议使用默认值,使用org.apache.hudi.hive.HiveMetastoreBasedLockProvider |
org.apache.hudi.client.transaction.lock.ZookeeperBasedLockProvider |
hoodie.write.lock.hivemetastore.database |
Hive的database |
无 |
hoodie.write.lock.hivemetastore.table |
Hive的table name |
无 |
hoodie.write.lock.client.num_retries |
重试次数 |
10 |
hoodie.write.lock.client.wait_time_ms_between_retry |
重试间隔 |
10000 |
hoodie.write.lock.conflict.resolution.strategy |
lock provider类,必须是ConflictResolutionStrategy的子类 |
org.apache.hudi.client.transaction.SimpleConcurrentFileWritesConflictResolutionStrategy |
hoodie.write.lock.zookeeper.base_path |
存放ZNodes的路径,同一张表的并发写入需配置一致 |
无 |
hoodie.write.lock.zookeeper.lock_key |
ZNode的名称,建议与Hudi表名相同 |
无 |
hoodie.write.lock.zookeeper.connection_timeout_ms |
zk连接超时时间 |
15000 |
hoodie.write.lock.zookeeper.port |
zk端口号 |
无 |
hoodie.write.lock.zookeeper.url |
zk的url |
无 |
hoodie.write.lock.zookeeper.session_timeout_ms |
zk的session过期时间 |
60000 |
- MapReduce服务_如何使用MapReduce服务_MRS集群客户端安装与使用
- Hudi服务_什么是Hudi_如何使用Hudi
- 大数据分析是什么_使用MapReduce_创建MRS服务
- MapReduce服务_什么是存算分离_如何配置MRS集群存算分离
- MapReduce服务_什么是ClickHouse_如何使用ClickHouse
- MapReduce服务_什么是MapReduce服务_什么是HBase
- DWS资源管理_GaussDB(DWS)资源管理作用_DWS资源管控
- MapReduce服务_什么是HetuEngine_如何使用HetuEngine
- MapReduce服务_什么是Hue_如何使用Hue
- MapReduce服务_什么是Kafka_如何使用Kafka