(incubator-uniffle) branch master updated: [#2282] fix(spark3): Invoke with object self in DelegationRssShuffleManager (#2283)

[maobaolong]

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

maobaolong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-uniffle.git


The following commit(s) were added to refs/heads/master by this push:
     new b7c9ca59b [#2282] fix(spark3): Invoke with object self in 
DelegationRssShuffleManager (#2283)
b7c9ca59b is described below

commit b7c9ca59b1413fa480fa0cfec666e9d15d77dcf9
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,