You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by le...@apache.org on 2023/11/10 07:06:41 UTC
(flink) 04/08: [FLINK-33023][table-planner][JUnit5 Migration] Module: flink-table-planner/connector (TableTestBase)
This is an automated email from the ASF dual-hosted git repository.
leonard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 6564bccbcb219a1e1eb641e2b54c51842cb56762
Author: Jiabao Sun <ji...@xtransfer.cn>
AuthorDate: Tue Sep 12 14:55:19 2023 +0800
[FLINK-33023][table-planner][JUnit5 Migration] Module: flink-table-planner/connector (TableTestBase)
---
.../connector/file/table/FileSystemTableSourceTest.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git a/flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/file/table/FileSystemTableSourceTest.java b/flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/file/table/FileSystemTableSourceTest.java
index 3b3b71a7e10..358f5ed5776 100644
--- a/flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/file/table/FileSystemTableSourceTest.java
+++ b/flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/file/table/FileSystemTableSourceTest.java
@@ -23,16 +23,16 @@ import org.apache.flink.table.api.TableEnvironment;
import org.apache.flink.table.planner.utils.StreamTableTestUtil;
import org.apache.flink.table.planner.utils.TableTestBase;
-import org.junit.Before;
-import org.junit.Test;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
/** Test for {@link FileSystemTableSource}. */
-public class FileSystemTableSourceTest extends TableTestBase {
+class FileSystemTableSourceTest extends TableTestBase {
private StreamTableTestUtil util;
- @Before
- public void setup() {
+ @BeforeEach
+ void setup() {
util = streamTestUtil(TableConfig.getDefault());
TableEnvironment tEnv = util.getTableEnv();
@@ -71,12 +71,12 @@ public class FileSystemTableSourceTest extends TableTestBase {
}
@Test
- public void testFilterPushDown() {
+ void testFilterPushDown() {
util.verifyRelPlanInsert("insert into MySink select * from MyTable where a > 10");
}
@Test
- public void testMetadataReading() {
+ void testMetadataReading() {
util.verifyRelPlanInsert(
"insert into MySink(a, b, c) select a, b, filemeta from MyTableWithMeta");
}