From 4af742dee299a6456251d50f6b6c9845a18358c4 Mon Sep 17 00:00:00 2001
From: "zhongqiang.czq" <zhongqiang.czq@alibaba-inc.com>
Date: Mon, 28 Aug 2023 10:09:19 +0800
Subject: [PATCH] fix flink ut error

---
 .../scala/org/apache/celeborn/tests/flink/WordCountTest.scala   | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/tests/flink-it/src/test/scala/org/apache/celeborn/tests/flink/WordCountTest.scala b/tests/flink-it/src/test/scala/org/apache/celeborn/tests/flink/WordCountTest.scala
index bcf68a4b65f..0c898849fe2 100644
--- a/tests/flink-it/src/test/scala/org/apache/celeborn/tests/flink/WordCountTest.scala
+++ b/tests/flink-it/src/test/scala/org/apache/celeborn/tests/flink/WordCountTest.scala
@@ -52,6 +52,8 @@ class WordCountTest extends AnyFunSuite with Logging with MiniClusterFeature
     logInfo("all test complete , stop celeborn mini cluster")
     if (flinkCluster != null) {
       flinkCluster.close()
+      flinkCluster = null
+      System.gc()
     }
     shutdownMiniCluster()
   }