From b7c9ca59b1413fa480fa0cfec666e9d15d77dcf9 Mon Sep 17 00:00:00 2001
From: Junfan Zhang <zuston@apache.org>
Date: Wed, 11 Dec 2024 09:30:19 +0800
Subject: [PATCH] [#2282] fix(spark3): Invoke with object self in
 DelegationRssShuffleManager (#2283)

Co-authored-by: Junfan Zhang <zhangjunfan@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
---
 .../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 aaa2c10925..dfdf587c33 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 <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,