fix flink ut error

apache · Aug 28, 2023 · 4af742d · 4af742d
1 parent 5d0c69f
commit 4af742d
Showing 1 changed file with 2 additions and 0 deletions.
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
@@ -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()
   }