(flink) 02/02: [FLINK-33470] Deleting JoinJsonPlanTest.java and JoinJsonPlanITCase.java
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 78b0a625f49058d0c0213de49d6337a7d4f2ab72
Author: Jim Hughes
AuthorDate: Tue Nov 7 17:14:09 2023 -0500
[FLINK-33470] Deleting JoinJsonPlanTest.java and JoinJsonPlanITCase.java
This closes #23869
---
.../plan/nodes/exec/stream/JoinJsonPlanTest.java | 144 ---
.../stream/jsonplan/JoinJsonPlanITCase.java| 168
.../JoinJsonPlanTest_jsonplan/testInnerJoin.out| 222 --
.../testInnerJoinWithEqualPk.out | 332 ---
.../testInnerJoinWithPk.out| 450 -
.../testLeftJoinNonEqui.out| 266
6 files changed, 1582 deletions(-)
diff --git
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest.java
b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest.java
deleted file mode 100644
index dd2771ea7cf..000
---
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest.java
+++ /dev/null
@@ -1,144 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.flink.table.planner.plan.nodes.exec.stream;
-
-import org.apache.flink.table.api.TableConfig;
-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.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Test;
-
-/** Test json serialization/deserialization for join. */
-class JoinJsonPlanTest extends TableTestBase {
-
-private StreamTableTestUtil util;
-private TableEnvironment tEnv;
-
-@BeforeEach
-void setup() {
-util = streamTestUtil(TableConfig.getDefault());
-tEnv = util.getTableEnv();
-
-String srcTableA =
-"CREATE TABLE A (\n"
-+ " a1 int,\n"
-+ " a2 bigint,\n"
-+ " a3 bigint\n"
-+ ") with (\n"
-+ " 'connector' = 'values',\n"
-+ " 'bounded' = 'false')";
-String srcTableB =
-"CREATE TABLE B (\n"
-+ " b1 int,\n"
-+ " b2 bigint,\n"
-+ " b3 bigint\n"
-+ ") with (\n"
-+ " 'connector' = 'values',\n"
-+ " 'bounded' = 'false')";
-String srcTableT =
-"CREATE TABLE t (\n"
-+ " a int,\n"
-+ " b bigint,\n"
-+ " c varchar\n"
-+ ") with (\n"
-+ " 'connector' = 'values',\n"
-+ " 'bounded' = 'false')";
-String srcTableS =
-"CREATE TABLE s (\n"
-+ " x bigint,\n"
-+ " y varchar,\n"
-+ " z int\n"
-+ ") with (\n"
-+ " 'connector' = 'values',\n"
-+ " 'bounded' = 'false')";
-tEnv.executeSql(srcTableA);
-tEnv.executeSql(srcTableB);
-tEnv.executeSql(srcTableT);
-tEnv.executeSql(srcTableS);
-}
-
-@Test
-void testInnerJoin() {
-String sinkTableDdl =
-"CREATE TABLE MySink (\n"
-+ " a1 int,\n"
-+ " b1 int\n"
-+ ") with (\n"
-+ " 'connector' = 'values',\n"
-+ " 'table-sink-class' = 'DEFAULT')";
-tEnv.executeSql(sinkTableDdl);
-util.verifyJsonPlan("INSERT INTO MySink SELECT a1, b1 FROM A JOIN B ON
a1 = b1");
-}
-
-@Test
-void testInnerJoinWithEqualPk() {
-String query1 = "SELECT SUM(a2) AS a2, a1 FROM A GROUP BY a
(flink) 02/02: [FLINK-33470] Deleting JoinJsonPlanTest.java and JoinJsonPlanITCase.java
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 5edc7d7b18e88cc86e84d197202d8cbb40621864
Author: Jim Hughes
AuthorDate: Tue Nov 7 17:14:09 2023 -0500
[FLINK-33470] Deleting JoinJsonPlanTest.java and JoinJsonPlanITCase.java
Removing json test files as well.
---
.../plan/nodes/exec/stream/JoinJsonPlanTest.java | 144 ---
.../stream/jsonplan/JoinJsonPlanITCase.java| 168
.../JoinJsonPlanTest_jsonplan/testInnerJoin.out| 222 --
.../testInnerJoinWithEqualPk.out | 332 ---
.../testInnerJoinWithPk.out| 450 -
.../testLeftJoinNonEqui.out| 266
6 files changed, 1582 deletions(-)
diff --git
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest.java
b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest.java
deleted file mode 100644
index dd2771ea7cf..000
---
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest.java
+++ /dev/null
@@ -1,144 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.flink.table.planner.plan.nodes.exec.stream;
-
-import org.apache.flink.table.api.TableConfig;
-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.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Test;
-
-/** Test json serialization/deserialization for join. */
-class JoinJsonPlanTest extends TableTestBase {
-
-private StreamTableTestUtil util;
-private TableEnvironment tEnv;
-
-@BeforeEach
-void setup() {
-util = streamTestUtil(TableConfig.getDefault());
-tEnv = util.getTableEnv();
-
-String srcTableA =
-"CREATE TABLE A (\n"
-+ " a1 int,\n"
-+ " a2 bigint,\n"
-+ " a3 bigint\n"
-+ ") with (\n"
-+ " 'connector' = 'values',\n"
-+ " 'bounded' = 'false')";
-String srcTableB =
-"CREATE TABLE B (\n"
-+ " b1 int,\n"
-+ " b2 bigint,\n"
-+ " b3 bigint\n"
-+ ") with (\n"
-+ " 'connector' = 'values',\n"
-+ " 'bounded' = 'false')";
-String srcTableT =
-"CREATE TABLE t (\n"
-+ " a int,\n"
-+ " b bigint,\n"
-+ " c varchar\n"
-+ ") with (\n"
-+ " 'connector' = 'values',\n"
-+ " 'bounded' = 'false')";
-String srcTableS =
-"CREATE TABLE s (\n"
-+ " x bigint,\n"
-+ " y varchar,\n"
-+ " z int\n"
-+ ") with (\n"
-+ " 'connector' = 'values',\n"
-+ " 'bounded' = 'false')";
-tEnv.executeSql(srcTableA);
-tEnv.executeSql(srcTableB);
-tEnv.executeSql(srcTableT);
-tEnv.executeSql(srcTableS);
-}
-
-@Test
-void testInnerJoin() {
-String sinkTableDdl =
-"CREATE TABLE MySink (\n"
-+ " a1 int,\n"
-+ " b1 int\n"
-+ ") with (\n"
-+ " 'connector' = 'values',\n"
-+ " 'table-sink-class' = 'DEFAULT')";
-tEnv.executeSql(sinkTableDdl);
-util.verifyJsonPlan("INSERT INTO MySink SELECT a1, b1 FROM A JOIN B ON
a1 = b1");
-}
-
-@Test
-void testInnerJoinWithEqualPk() {
-String query1 = "SELECT SUM(a2) AS a2, a1 FR
