You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uniffle.apache.org by ro...@apache.org on 2022/09/02 03:27:11 UTC

[incubator-uniffle] branch master updated: [MINOR] Replace HashSet with ImmutableSet in configs (#195)

This is an automated email from the ASF dual-hosted git repository.

roryqi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-uniffle.git


The following commit(s) were added to refs/heads/master by this push:
     new 331ebb2a [MINOR] Replace HashSet with ImmutableSet in configs (#195)
331ebb2a is described below

commit 331ebb2a7cd12dfa5d780fc4b0b7d11e9917d343
Author: Kaijie Chen <ck...@apache.org>
AuthorDate: Fri Sep 2 11:27:07 2022 +0800

    [MINOR] Replace HashSet with ImmutableSet in configs (#195)
    
    ### What changes were proposed in this pull request?
    
    Replace HashSet with ImmutableSet in RssMRConfigs and RssSparkConfigs.
    
    ### Why are the changes needed?
    
    It's error prone to use mutable collection in public static fields.
    
    ### Does this PR introduce _any_ user-facing change?
    
    No.
    
    ### How was this patch tested?
    
    CI.
---
 .../src/main/java/org/apache/hadoop/mapreduce/RssMRConfig.java      | 6 +++---
 .../src/main/java/org/apache/spark/shuffle/RssSparkConfig.java      | 4 ++--
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/client-mr/src/main/java/org/apache/hadoop/mapreduce/RssMRConfig.java b/client-mr/src/main/java/org/apache/hadoop/mapreduce/RssMRConfig.java
index 1c98bdab..eb518162 100644
--- a/client-mr/src/main/java/org/apache/hadoop/mapreduce/RssMRConfig.java
+++ b/client-mr/src/main/java/org/apache/hadoop/mapreduce/RssMRConfig.java
@@ -19,7 +19,7 @@ package org.apache.hadoop.mapreduce;
 
 import java.util.Set;
 
-import com.google.common.collect.Sets;
+import com.google.common.collect.ImmutableSet;
 
 import org.apache.uniffle.client.util.RssClientConfig;
 
@@ -162,6 +162,6 @@ public class RssMRConfig {
   
   public static final String RSS_CONF_FILE = "rss_conf.xml";
 
-  public static final Set<String> RSS_MANDATORY_CLUSTER_CONF = Sets.newHashSet(
-      RSS_STORAGE_TYPE, RSS_REMOTE_STORAGE_PATH);
+  public static final Set<String> RSS_MANDATORY_CLUSTER_CONF =
+      ImmutableSet.of(RSS_STORAGE_TYPE, RSS_REMOTE_STORAGE_PATH);
 }
diff --git a/client-spark/common/src/main/java/org/apache/spark/shuffle/RssSparkConfig.java b/client-spark/common/src/main/java/org/apache/spark/shuffle/RssSparkConfig.java
index 67e29719..5a46da3e 100644
--- a/client-spark/common/src/main/java/org/apache/spark/shuffle/RssSparkConfig.java
+++ b/client-spark/common/src/main/java/org/apache/spark/shuffle/RssSparkConfig.java
@@ -19,7 +19,7 @@ package org.apache.spark.shuffle;
 
 import java.util.Set;
 
-import com.google.common.collect.Sets;
+import com.google.common.collect.ImmutableSet;
 import org.apache.spark.internal.config.ConfigBuilder;
 import org.apache.spark.internal.config.ConfigEntry;
 import org.apache.spark.internal.config.TypedConfigBuilder;
@@ -231,7 +231,7 @@ public class RssSparkConfig {
       .createWithDefault("");
 
   public static final Set<String> RSS_MANDATORY_CLUSTER_CONF =
-      Sets.newHashSet(RSS_STORAGE_TYPE.key(), RSS_REMOTE_STORAGE_PATH.key());
+      ImmutableSet.of(RSS_STORAGE_TYPE.key(), RSS_REMOTE_STORAGE_PATH.key());
 
   public static final boolean RSS_USE_RSS_SHUFFLE_MANAGER_DEFAULT_VALUE = false;