[#2282] fix(spark3): Invoke with object self in DelegationRssShuffleM…

…anager (#2283) Co-authored-by: Junfan Zhang <[email protected]> ### What changes were proposed in this pull request? Fix the bug of none object self when invoking the reflection method. ### Why are the changes needed? Fix: #2282 ### Does this PR introduce _any_ user-facing change? No. ### How was this patch tested? Existing tests
apache · Dec 11, 2024 · b7c9ca5 · b7c9ca5
1 parent 44bfd0d
commit b7c9ca5
Showing 1 changed file with 2 additions and 0 deletions.
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
@@ -247,6 +247,7 @@ public <K, C> ShuffleReader<K, C> getReader(
                       TaskContext.class,
                       ShuffleReadMetricsReporter.class)
                   .invoke(
+                      delegate,
                       handle,
                       startMapIndex,
                       endMapIndex,
@@ -285,6 +286,7 @@ public <K, C> ShuffleReader<K, C> getReaderForRange(
                       TaskContext.class,
                       ShuffleReadMetricsReporter.class)
                   .invoke(
+                      delegate,
                       handle,
                       startMapIndex,
                       endMapIndex,