Skip to content

Commit d820042

Browse files
committed
reset listener
1 parent aa3bbeb commit d820042

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -274,6 +274,7 @@ public void stop() {
274274
_sortShuffleManager.stop();
275275
_sortShuffleManager = null;
276276
}
277+
ListenerHelper.reset();
277278
}
278279

279280
@Override

0 commit comments

Comments
 (0)