Fix camel style config

apache · Nov 18, 2024 · 4950a88 · 4950a88
1 parent 209ecee
commit 4950a88
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
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
@@ -323,7 +323,7 @@ public class RssSparkConfig {
   public static final ConfigEntry<String> RSS_ACCESS_ID =
       createStringBuilder(new ConfigBuilder("spark.rss.access.id")).createWithDefault("");
   public static final ConfigEntry<String> RSS_ACCESS_ID_PROVIDER_KEY =
-      createStringBuilder(new ConfigBuilder("spark.rss.access.id.provider.key"))
+      createStringBuilder(new ConfigBuilder("spark.rss.access.id.providerKey"))
           .createWithDefault("");
 
   public static final ConfigEntry<Integer> RSS_ACCESS_TIMEOUT_MS =

diff --git a/client-spark/spark3/src/main/java/org/apache/spark/shuffle/DelegationRssShuffleManager.java b/client-spark/spark3/src/main/java/org/apache/spark/shuffle/DelegationRssShuffleManager.java
@@ -112,7 +112,7 @@ private ShuffleManager createShuffleManagerInDriver() throws RssException {
   private boolean tryAccessCluster() {
     String accessId = sparkConf.get(RssSparkConfig.RSS_ACCESS_ID.key(), "").trim();
     if (StringUtils.isEmpty(accessId)) {
-      String providerKey = sparkConf.get(RssSparkConfig.RSS_ACCESS_ID.key(), "");
+      String providerKey = sparkConf.get(RssSparkConfig.RSS_ACCESS_ID_PROVIDER_KEY.key(), "");
       if (StringUtils.isNotEmpty(accessId)) {
         accessId = sparkConf.get(providerKey, "");
         LOG.info("Get access id {} from provider key: {}", accessId, providerKey);