[MINOR] mr: fix default value

zhengchenyu · Jul 26, 2023 · e755550 · e755550
1 parent ecfed5e
commit e755550
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/README.md b/README.md
@@ -167,7 +167,7 @@ rss-xxx.tgz will be generated for deployment
  # multiple remote storages are supported, and client will get assignment from coordinator
  rss.coordinator.remote.storage.path hdfs://cluster1/path,hdfs://cluster2/path
  rss.writer.require.memory.retryMax 1200
- rss.client.retry.max 100
+ rss.client.retry.max 50
  rss.writer.send.check.timeout 600000
  rss.client.read.buffer.size 14m
  ```

diff --git a/client-mr/core/src/main/java/org/apache/hadoop/mapreduce/v2/app/RssMRAppMaster.java b/client-mr/core/src/main/java/org/apache/hadoop/mapreduce/v2/app/RssMRAppMaster.java
@@ -137,7 +137,7 @@ public static void main(String[] args) {
  assignmentTags.addAll(Arrays.asList(rawTags.split(",")));
  }
  assignmentTags.add(Constants.SHUFFLE_SERVER_VERSION);
- String clientType = conf.get(RssMRConfig.RSS_CLIENT_TYPE);
+ String clientType = conf.get(RssMRConfig.RSS_CLIENT_TYPE, RssMRConfig.RSS_CLIENT_TYPE_DEFAULT_VALUE);
  ClientUtils.validateClientType(clientType);
  assignmentTags.add(clientType);