From 4afa783307e4163a19fbcd72a17cbb158fe54e87 Mon Sep 17 00:00:00 2001
From: Junfan Zhang <zhangjunfan@qiyi.com>
Date: Tue, 10 Dec 2024 10:27:44 +0800
Subject: [PATCH] [#2282] fix(spark3): Invoke with object self in
 DelegationRssShuffleManager

---
 .../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,