(uniffle) 02/11: [#2282] fix(spark3): Invoke with object self in DelegationRssShuffleManager (#2283)

[roryqi]

This is an automated email from the ASF dual-hosted git repository.

roryqi pushed a commit to branch branch-0.10.bak
in repository https://gitbox.apache.org/repos/asf/uniffle.git

commit 7ca24bb388964ab302a5bb5dab1a1b6f121b52f3
Author: Junfan Zhang <zus...@apache.org>
AuthorDate: Wed Dec 11 09:30:19 2024 +0800

    [#2282] fix(spark3): Invoke with object self in DelegationRssShuffleManager 
(#2283)
    
    Co-authored-by: Junfan Zhang <zhangjun...@qiyi.com>
    
    ### 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
---
 .../main/java/org/apache/spark/shuffle/DelegationRssShuffleManager.java | 2 ++
 1 file changed, 2 insertions(+)

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
index aaa2c1092..dfdf587c3 100644
--- 
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 class DelegationRssShuffleManager implements 
ShuffleManager {
                       TaskContext.class,
                       ShuffleReadMetricsReporter.class)
                   .invoke(
+                      delegate,
                       handle,
                       startMapIndex,
                       endMapIndex,
@@ -285,6 +286,7 @@ public class DelegationRssShuffleManager implements 
ShuffleManager {
                       TaskContext.class,
                       ShuffleReadMetricsReporter.class)
                   .invoke(
+                      delegate,
                       handle,
                       startMapIndex,
                       endMapIndex,