[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1070230669 ## core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala: ## @@ -366,8 +359,35 @@ class BlockManagerMasterEndpoint( }

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1070212293 ## core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala: ## @@ -366,8 +359,35 @@ class BlockManagerMasterEndpoint( }

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1069857650 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalBlockStoreClient.java: ## @@ -256,6 +256,23 @@ public void onFailure(Throwable e) {

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1068956139 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalBlockStoreClient.java: ## @@ -256,6 +256,23 @@ public void onFailure(Throwable e) {

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1068472060 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalBlockStoreClient.java: ## @@ -256,6 +256,22 @@ public void onFailure(Throwable e) {

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1068470671 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -470,6 +530,40 @@ void closeAndDeleteOutdatedPartitions(

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1068018231 ## core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala: ## @@ -913,6 +918,59 @@ class MapOutputTrackerSuite extends SparkFunSuite with LocalSparkContext

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067941354 ## core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala: ## @@ -321,6 +321,12 @@ class BlockManagerMasterEndpoint( } private def

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067973800 ## core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala: ## @@ -321,6 +321,12 @@ class BlockManagerMasterEndpoint( } private def

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067973800 ## core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala: ## @@ -321,6 +321,12 @@ class BlockManagerMasterEndpoint( } private def

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067973800 ## core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala: ## @@ -321,6 +321,12 @@ class BlockManagerMasterEndpoint( } private def

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067973800 ## core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala: ## @@ -321,6 +321,12 @@ class BlockManagerMasterEndpoint( } private def

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067973800 ## core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala: ## @@ -321,6 +321,12 @@ class BlockManagerMasterEndpoint( } private def

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067973800 ## core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala: ## @@ -321,6 +321,12 @@ class BlockManagerMasterEndpoint( } private def

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067941354 ## core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala: ## @@ -321,6 +321,12 @@ class BlockManagerMasterEndpoint( } private def

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067941354 ## core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala: ## @@ -321,6 +321,12 @@ class BlockManagerMasterEndpoint( } private def

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067941354 ## core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala: ## @@ -321,6 +321,12 @@ class BlockManagerMasterEndpoint( } private def

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067941354 ## core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala: ## @@ -321,6 +321,12 @@ class BlockManagerMasterEndpoint( } private def

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067941354 ## core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala: ## @@ -321,6 +321,12 @@ class BlockManagerMasterEndpoint( } private def

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067741652 ## core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala: ## @@ -321,6 +321,12 @@ class BlockManagerMasterEndpoint( } private def

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067733179 ## core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala: ## @@ -321,6 +321,12 @@ class BlockManagerMasterEndpoint( } private def

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067637314 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalBlockStoreClient.java: ## @@ -256,6 +256,22 @@ public void onFailure(Throwable e) {

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067554329 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/NoOpMergedShuffleFileManager.java: ## @@ -84,4 +85,9 @@ public MergedBlockMeta

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067551485 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalBlockStoreClient.java: ## @@ -256,6 +256,22 @@ public void onFailure(Throwable e) {

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067551485 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalBlockStoreClient.java: ## @@ -256,6 +256,22 @@ public void onFailure(Throwable e) {

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067551485 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalBlockStoreClient.java: ## @@ -256,6 +256,22 @@ public void onFailure(Throwable e) {

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067551485 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalBlockStoreClient.java: ## @@ -256,6 +256,22 @@ public void onFailure(Throwable e) {

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067551485 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalBlockStoreClient.java: ## @@ -256,6 +256,22 @@ public void onFailure(Throwable e) {

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1067548067 ## core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala: ## @@ -321,6 +321,12 @@ class BlockManagerMasterEndpoint( } private def

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1066433357 ## core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala: ## @@ -366,8 +372,19 @@ class BlockManagerMasterEndpoint( }

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1066428217 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -396,6 +403,67 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1063954257 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -470,6 +527,39 @@ void closeAndDeleteOutdatedPartitions(

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1059526011 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -396,6 +403,56 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1059526338 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -396,6 +403,67 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1059526011 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -396,6 +403,56 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1057911122 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -396,6 +403,67 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1053970574 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -396,6 +403,56 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1053970574 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -396,6 +403,56 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1054099320 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -396,6 +403,56 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r1027637860 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -393,6 +394,35 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r990820843 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -650,24 +666,28 @@ public MergeStatuses

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r990763769 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -393,6 +393,22 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r990763769 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -393,6 +393,22 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r990763769 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -393,6 +393,22 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r990763769 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -393,6 +393,22 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r990763769 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -393,6 +393,22 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r990763769 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -393,6 +393,22 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r990763769 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -393,6 +393,22 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r990756966 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -1410,26 +1431,27 @@ public String toString() { *

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r990763769 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -393,6 +393,22 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r990763769 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -393,6 +393,22 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r990763769 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -393,6 +393,22 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r990763769 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -393,6 +393,22 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r990753031 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java: ## @@ -393,6 +393,22 @@ public void applicationRemoved(String

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE] Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r990751884 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalBlockHandler.java: ## @@ -224,6 +224,12 @@ protected void handleMessage( }

[GitHub] [spark] mridulm commented on a diff in pull request #37922: [SPARK-40480][SHUFFLE]Remove push-based shuffle data after query finished

mridulm commented on code in PR #37922: URL: https://github.com/apache/spark/pull/37922#discussion_r973756877 ## common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/BlockStoreClient.java: ## @@ -255,4 +255,17 @@ public void getMergedBlockMeta(