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 011f777036540d0f027b04306714bf9e64003a97
Author: bvarghese1 <bvargh...@confluent.io>
AuthorDate: Wed Dec 13 14:53:10 2023 -0800
[FLINK-33818] Remove WindowDeduplicateJsonITCase test
- This is covered by the new restore tests
---
.../jsonplan/WindowDeduplicateJsonITCase.java | 110 ---------------------
1 file changed, 110 deletions(-)
diff --git
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/WindowDeduplicateJsonITCase.java
b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/WindowDeduplicateJsonITCase.java
deleted file mode 100644
index ef2cd5d58d9..00000000000
---
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/WindowDeduplicateJsonITCase.java
+++ /dev/null
@@ -1,110 +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.runtime.stream.jsonplan;
-
-import org.apache.flink.table.planner.factories.TestValuesTableFactory;
-import org.apache.flink.table.planner.runtime.utils.TestData;
-import org.apache.flink.table.planner.utils.JavaScalaConversionUtil;
-import org.apache.flink.table.planner.utils.JsonPlanTestBase;
-
-import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Test;
-
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.List;
-
-/** Test for window deduplicate json plan. */
-class WindowDeduplicateJsonITCase extends JsonPlanTestBase {
-
- @BeforeEach
- @Override
- protected void setup() throws Exception {
- super.setup();
- createTestValuesSourceTable(
- "MyTable",
-
JavaScalaConversionUtil.toJava(TestData.windowDataWithTimestamp()),
- new String[] {
- "ts STRING",
- "`int` INT",
- "`double` DOUBLE",
- "`float` FLOAT",
- "`bigdec` DECIMAL(10, 2)",
- "`string` STRING",
- "`name` STRING",
- "`rowtime` AS TO_TIMESTAMP(`ts`)",
- "WATERMARK for `rowtime` AS `rowtime` - INTERVAL '1'
SECOND",
- },
- new HashMap<String, String>() {
- {
- put("enable-watermark-push-down", "true");
- put("failing-source", "true");
- }
- });
- }
-
- @Test
- void testEventTimeTumbleWindow() throws Exception {
- createTestValuesSinkTable(
- "MySink",
- "ts STRING",
- "`int` INT",
- "`double` DOUBLE",
- "`float` FLOAT",
- "`bigdec` DECIMAL(10, 2)",
- "`string` STRING",
- "`name` STRING",
- "`rowtime` STRING",
- "window_start TIMESTAMP(3)",
- "window_end TIMESTAMP(3)",
- "window_time TIMESTAMP(3)");
- compileSqlAndExecutePlan(
- "insert into MySink select\n"
- + " `ts`,\n"
- + " `int`,\n"
- + " `double`,\n"
- + " `float`, \n"
- + " `bigdec`, \n"
- + " `string`, \n"
- + " `name`, \n"
- + " CAST(`rowtime` AS STRING), \n"
- + " window_start, \n"
- + " window_end, \n"
- + " window_time \n"
- + "FROM (\n"
- + " SELECT *,\n"
- + " ROW_NUMBER() OVER( \n"
- + " PARTITION BY window_start,
window_end, `name` ORDER BY rowtime DESC) as rownum \n"
- + " FROM TABLE( \n"
- + " TUMBLE(TABLE MyTable,
DESCRIPTOR(rowtime), INTERVAL '5' SECOND))) \n"
- + "WHERE rownum <= 1")
- .await();
-
- List<String> result =
TestValuesTableFactory.getResultsAsStrings("MySink");
- assertResult(
- Arrays.asList(
- "+I[2020-10-10 00:00:04, 5, 5.0, 5.0, 5.55, null, a,
2020-10-10 00:00:04.000, 2020-10-10T00:00, 2020-10-10T00:00:05,
2020-10-10T00:00:04.999]",
- "+I[2020-10-10 00:00:08, 3, null, 3.0, 3.33,
Comment#2, a, 2020-10-10 00:00:08.000, 2020-10-10T00:00:05,
2020-10-10T00:00:10, 2020-10-10T00:00:09.999]",
- "+I[2020-10-10 00:00:07, 3, 3.0, 3.0, null, Hello, b,
2020-10-10 00:00:07.000, 2020-10-10T00:00:05, 2020-10-10T00:00:10,
2020-10-10T00:00:09.999]",
- "+I[2020-10-10 00:00:16, 4, 4.0, 4.0, 4.44, Hi, b,
2020-10-10 00:00:16.000, 2020-10-10T00:00:15, 2020-10-10T00:00:20,
2020-10-10T00:00:19.999]",
- "+I[2020-10-10 00:00:32, 7, 7.0, 7.0, 7.77, null,
null, 2020-10-10 00:00:32.000, 2020-10-10T00:00:30, 2020-10-10T00:00:35,
2020-10-10T00:00:34.999]",
- "+I[2020-10-10 00:00:34, 1, 3.0, 3.0, 3.33, Comment#3,
b, 2020-10-10 00:00:34.000, 2020-10-10T00:00:30, 2020-10-10T00:00:35,
2020-10-10T00:00:34.999]"),
- result);
- }
-}
