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); - } -}