fix

zuston · Jan 5, 2024 · 6c40488 · 6c40488
1 parent 9f2346b
commit 6c40488
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/client-spark/spark2/src/main/java/org/apache/spark/shuffle/RssShuffleManager.java b/client-spark/spark2/src/main/java/org/apache/spark/shuffle/RssShuffleManager.java
@@ -306,7 +306,7 @@ public <K, V, C> ShuffleHandle registerShuffle(
  }
 
  String storageType = sparkConf.get(RssSparkConfig.RSS_STORAGE_TYPE.key());
- RemoteStorageInfo defaultRemoteStorage = getRemoteStorageInfo(sparkConf);
+ RemoteStorageInfo defaultRemoteStorage = getDefaultRemoteStorageInfo(sparkConf);
  RemoteStorageInfo remoteStorage =
  ClientUtils.fetchRemoteStorage(
  appId, defaultRemoteStorage, dynamicConfEnabled, storageType, shuffleWriteClient);