You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by lz...@apache.org on 2020/03/19 12:31:35 UTC
[flink] branch release-1.10 updated: [FLINK-16675][test] Fix
TableEnvironmentITCase.testClearOperation failure
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.10 by this push:
new e9c0dd2 [FLINK-16675][test] Fix TableEnvironmentITCase.testClearOperation failure
e9c0dd2 is described below
commit e9c0dd2511adc1d09559434864ed268352a355d1
Author: Rui Li <li...@apache.org>
AuthorDate: Thu Mar 19 20:31:13 2020 +0800
[FLINK-16675][test] Fix TableEnvironmentITCase.testClearOperation failure
This closes #11449
---
.../test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala | 3 +++
1 file changed, 3 insertions(+)
diff --git a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala
index 646629b..8094bb9 100644
--- a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala
+++ b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala
@@ -35,6 +35,8 @@ import org.junit.{Assert, Rule, Test}
import _root_.java.io.File
import _root_.java.util
+import org.apache.flink.table.planner.factories.utils.TestCollectionTableFactory
+
@RunWith(classOf[Parameterized])
class TableEnvironmentITCase(settings: EnvironmentSettings, mode: String) {
@@ -135,6 +137,7 @@ class TableEnvironmentITCase(settings: EnvironmentSettings, mode: String) {
@Test
def testClearOperation(): Unit = {
+ TestCollectionTableFactory.reset()
val tableEnv = TableEnvironmentImpl.create(settings)
tableEnv.sqlUpdate("create table dest1(x map<int,bigint>) with('connector' = 'COLLECTION')")
tableEnv.sqlUpdate("create table dest2(x int) with('connector' = 'COLLECTION')")