[flink] branch master updated: [FLINK-17081][table-planner-blink] Extend batch integration tests with TestLogger

[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 73fa677  [FLINK-17081][table-planner-blink] Extend batch integration tests with TestLogger
73fa677 is described below

commit 73fa67736f51a8529d7107f93b84775f19cee5c9
Author: TsReaper <ts...@gmail.com>
AuthorDate: Fri Apr 10 22:43:57 2020 +0800

    [FLINK-17081][table-planner-blink] Extend batch integration tests with TestLogger
    
    This closes #11689
---
 .../org/apache/flink/table/api/TableUtilsStreamingITCase.java     | 3 ++-
 .../flink/table/planner/runtime/utils/BatchAbstractTestBase.java  | 3 ++-
 .../scala/org/apache/flink/table/api/TableEnvironmentITCase.scala | 8 +++-----
 3 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/api/TableUtilsStreamingITCase.java b/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/api/TableUtilsStreamingITCase.java
index 0c97472..89f134c 100644
--- a/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/api/TableUtilsStreamingITCase.java
+++ b/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/api/TableUtilsStreamingITCase.java
@@ -22,6 +22,7 @@ import org.apache.flink.streaming.api.TimeCharacteristic;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 import org.apache.flink.table.api.java.StreamTableEnvironment;
 import org.apache.flink.types.Row;
+import org.apache.flink.util.TestLogger;
 
 import org.junit.Before;
 import org.junit.Test;
@@ -36,7 +37,7 @@ import static org.junit.Assert.assertEquals;
 /**
  * IT case for {@link TableUtils} in streaming mode.
  */
-public class TableUtilsStreamingITCase {
+public class TableUtilsStreamingITCase extends TestLogger {
 
 	private StreamExecutionEnvironment env;
 	private StreamTableEnvironment tEnv;
diff --git a/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/utils/BatchAbstractTestBase.java b/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/utils/BatchAbstractTestBase.java
index ff910eb..099d92c 100644
--- a/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/utils/BatchAbstractTestBase.java
+++ b/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/utils/BatchAbstractTestBase.java
@@ -23,6 +23,7 @@ import org.apache.flink.configuration.MemorySize;
 import org.apache.flink.configuration.TaskManagerOptions;
 import org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration;
 import org.apache.flink.test.util.MiniClusterWithClientResource;
+import org.apache.flink.util.TestLogger;
 
 import org.junit.ClassRule;
 import org.junit.rules.TemporaryFolder;
@@ -31,7 +32,7 @@ import org.junit.rules.TemporaryFolder;
 /**
  * Batch test base to use {@link ClassRule}.
  */
-public class BatchAbstractTestBase {
+public class BatchAbstractTestBase extends TestLogger {
 
 	public static final int DEFAULT_PARALLELISM = 3;
 
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 ad003c5..7bda63e 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
@@ -27,12 +27,13 @@ import org.apache.flink.streaming.api.scala.{StreamExecutionEnvironment => Scala
 import org.apache.flink.table.api.internal.TableEnvironmentImpl
 import org.apache.flink.table.api.java.StreamTableEnvironment
 import org.apache.flink.table.api.scala.{StreamTableEnvironment => ScalaStreamTableEnvironment, _}
+import org.apache.flink.table.planner.factories.utils.TestCollectionTableFactory
 import org.apache.flink.table.planner.runtime.utils.TestingAppendSink
 import org.apache.flink.table.planner.utils.TableTestUtil.{readFromResource, replaceStageId}
 import org.apache.flink.table.planner.utils.TestTableSources.getPersonCsvTableSource
 import org.apache.flink.table.sinks.CsvTableSink
 import org.apache.flink.types.Row
-import org.apache.flink.util.FileUtils
+import org.apache.flink.util.{FileUtils, TestLogger}
 
 import org.junit.Assert.{assertEquals, assertFalse, assertTrue}
 import org.junit.rules.TemporaryFolder
@@ -42,14 +43,11 @@ import org.junit.{Assert, Before, Rule, Test}
 
 import _root_.java.io.File
 import _root_.java.util
-
-import org.apache.flink.table.planner.factories.utils.TestCollectionTableFactory
-
 import _root_.scala.collection.mutable
 
 
 @RunWith(classOf[Parameterized])
-class TableEnvironmentITCase(tableEnvName: String, isStreaming: Boolean) {
+class TableEnvironmentITCase(tableEnvName: String, isStreaming: Boolean) extends TestLogger {
 
   private val _tempFolder = new TemporaryFolder()