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 <tsreape...@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()
