diff --git a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala
index 60a9fa9bb3d8468c730d07bf44d39fe66ba06924..70c1c62e98c6f5f84428b66fdd99c9ea075ba50a 100644
--- a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala
+++ b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala
@@ -35,15 +35,13 @@ import org.apache.flink.table.utils.TableTestUtil.{readFromResource, replaceStag
 import org.apache.flink.table.utils.{TestTableSourceWithTime, TestingOverwritableTableSink}
 import org.apache.flink.types.Row
 import org.apache.flink.util.FileUtils
-
 import org.apache.flink.shaded.guava18.com.google.common.collect.Lists
-
 import org.hamcrest.Matchers.containsString
 import org.junit.Assert.{assertEquals, assertFalse, assertTrue}
 import org.junit.rules.{ExpectedException, TemporaryFolder}
 import org.junit.runner.RunWith
 import org.junit.runners.Parameterized
-import org.junit.{Before, Rule, Test}
+import org.junit.{After, Before, Rule, Test}
 
 import _root_.java.io.{File, FileOutputStream, OutputStreamWriter}
 import _root_.java.lang.{Long => JLong}
@@ -84,6 +82,11 @@ class TableEnvironmentITCase(tableEnvName: String) {
     tEnv.registerTableSource("MyTable", getPersonCsvTableSource)
   }
 
+  @After
+  def teardown(): Unit = {
+    StreamITCase.clear
+  }
+
   @Test
   def testExecuteTwiceUsingSameTableEnv(): Unit = {
     val sink1Path = registerCsvTableSink(tEnv, Array("first"), Array(STRING), "MySink1")
@@ -335,6 +338,7 @@ class TableEnvironmentITCase(tableEnvName: String) {
     streamTableEnv.registerTableSource("MyTable", getPersonCsvTableSource)
     val sink1Path = registerCsvTableSink(streamTableEnv, Array("first"), Array(STRING), "MySink1")
     checkEmptyFile(sink1Path)
+    StreamITCase.clear
 
     val table = streamTableEnv.sqlQuery("select last from MyTable where id > 0")
     val resultSet = streamTableEnv.toAppendStream(table, classOf[Row])