[flink] branch master updated: [hotfix][FLINK-12830][table-planner] Fix fragile TableSinkITCase#testBoundedTableSink test

[ja...@apache.org]

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

jark pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 180fe43  [hotfix][FLINK-12830][table-planner] Fix fragile TableSinkITCase#testBoundedTableSink test
180fe43 is described below

commit 180fe43e9edea9b38e4022af81e7fe9080ff9c9a
Author: 云邪 <wu...@alibaba-inc.com>
AuthorDate: Thu Jun 13 18:30:17 2019 +0800

    [hotfix][FLINK-12830][table-planner] Fix fragile TableSinkITCase#testBoundedTableSink test
---
 .../org/apache/flink/table/runtime/batch/table/TableSinkITCase.scala   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/runtime/batch/table/TableSinkITCase.scala b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/runtime/batch/table/TableSinkITCase.scala
index adb1a40..d64df26 100644
--- a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/runtime/batch/table/TableSinkITCase.scala
+++ b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/runtime/batch/table/TableSinkITCase.scala
@@ -75,9 +75,10 @@ class TableSinkITCase(
   }
 
   @Test
-  def testBoundedTableSink(): Unit = {
+  def testOutputFormatTableSink(): Unit = {
     val env = ExecutionEnvironment.getExecutionEnvironment
     val tEnv = BatchTableEnvironment.create(env, config)
+    MemoryTableSourceSinkUtil.clear()
 
     val fieldNames = Array("c", "b")
     val fieldTypes: Array[TypeInformation[_]] = Array(Types.STRING, Types.LONG)