[incubator-celeborn] branch main updated: [CELEBORN-154] replace shuffleclient's shutDown to shutdown (#1098)

[ethanfeng]

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

ethanfeng pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git


The following commit(s) were added to refs/heads/main by this push:
     new d31c94a9 [CELEBORN-154] replace shuffleclient's shutDown to shutdown 
(#1098)
d31c94a9 is described below

commit d31c94a903ed1bd8bc48b3b906c92c0e00b6f842
Author: zhongqiangczq <96606293+zhongqiang...@users.noreply.github.com>
AuthorDate: Mon Dec 19 09:33:44 2022 +0800

    [CELEBORN-154] replace shuffleclient's shutDown to shutdown (#1098)
---
 .../java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGate.java  | 2 +-
 .../org/apache/celeborn/plugin/flink/RemoteShuffleOutputGateSuiteJ.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGate.java
 
b/client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGate.java
index e6f03e2a..b0f183fc 100644
--- 
a/client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGate.java
+++ 
b/client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGate.java
@@ -196,7 +196,7 @@ public class RemoteShuffleOutputGate {
       bufferPool.lazyDestroy();
     }
     bufferPacker.close();
-    shuffleWriteClient.shutDown();
+    shuffleWriteClient.shutdown();
   }
 
   /** Returns shuffle descriptor. */
diff --git 
a/client-flink/flink-1.14/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGateSuiteJ.java
 
b/client-flink/flink-1.14/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGateSuiteJ.java
index ca4c43e9..13cceb34 100644
--- 
a/client-flink/flink-1.14/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGateSuiteJ.java
+++ 
b/client-flink/flink-1.14/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGateSuiteJ.java
@@ -79,7 +79,7 @@ public class RemoteShuffleOutputGateSuiteJ {
         .mapperEnd(any(), anyInt(), anyInt(), anyInt(), anyInt());
     remoteShuffleOutputGate.finish();
 
-    doNothing().when(remoteShuffleOutputGate.shuffleWriteClient).shutDown();
+    doNothing().when(remoteShuffleOutputGate.shuffleWriteClient).shutdown();
     remoteShuffleOutputGate.close();
   }