From 6c404889638d6bf59f3241f7041a99efe68fcd48 Mon Sep 17 00:00:00 2001 From: Junfan Zhang Date: Fri, 5 Jan 2024 10:15:39 +0800 Subject: [PATCH] fix --- .../main/java/org/apache/spark/shuffle/RssShuffleManager.java | 2 +- 1 file changed, 1 insertion(+), 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 index 26cbd64126..fdcc167b53 100644 --- 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 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);