This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit f5d889fb70688bc3e29fc979dc233d2c9674fa96 Author: bvarghese1 <[email protected]> AuthorDate: Tue Jan 16 18:16:42 2024 -0800 [FLINK-33441] Move Union restore tests - Moving from nodes.exec.testutil to nodes.exec.stream - Related commit: f362dcc --- .../plan/nodes/exec/{testutils => stream}/UnionRestoreTest.java | 4 ++-- .../plan/nodes/exec/{testutils => stream}/UnionTestPrograms.java | 3 +-- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/UnionRestoreTest.java b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/UnionRestoreTest.java similarity index 90% rename from flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/UnionRestoreTest.java rename to flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/UnionRestoreTest.java index ca27c175fc6..b271e0221ad 100644 --- a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/UnionRestoreTest.java +++ b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/UnionRestoreTest.java @@ -16,9 +16,9 @@ * limitations under the License. */ -package org.apache.flink.table.planner.plan.nodes.exec.testutils; +package org.apache.flink.table.planner.plan.nodes.exec.stream; -import org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecUnion; +import org.apache.flink.table.planner.plan.nodes.exec.testutils.RestoreTestBase; import org.apache.flink.table.test.program.TableTestProgram; import java.util.Arrays; diff --git a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/UnionTestPrograms.java b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/UnionTestPrograms.java similarity index 98% rename from flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/UnionTestPrograms.java rename to flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/UnionTestPrograms.java index 562199588b5..e40ee481fce 100644 --- a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/UnionTestPrograms.java +++ b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/UnionTestPrograms.java @@ -16,9 +16,8 @@ * limitations under the License. */ -package org.apache.flink.table.planner.plan.nodes.exec.testutils; +package org.apache.flink.table.planner.plan.nodes.exec.stream; -import org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecUnion; import org.apache.flink.table.test.program.SinkTestStep; import org.apache.flink.table.test.program.SourceTestStep; import org.apache.flink.table.test.program.TableTestProgram;
