You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2024/07/04 09:07:50 UTC
(flink) branch master updated: [FLINK-34268] Removing exclusions for FLINK-33676 33805
This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new cc19159b489 [FLINK-34268] Removing exclusions for FLINK-33676 33805
cc19159b489 is described below
commit cc19159b489dafad71c01bf551bc224a38203eae
Author: Jim Hughes <jh...@confluent.io>
AuthorDate: Wed Jul 3 08:54:16 2024 -0400
[FLINK-34268] Removing exclusions for FLINK-33676 33805
When FLINK-34268 was initially implemented, FLINK-33676 and FLINK-33805 had not landed.
Given that, there were exclusions hard-coded. This PR removes those.
---
.../plan/nodes/exec/testutils/RestoreTestCompleteness.java | 12 ------------
1 file changed, 12 deletions(-)
diff --git a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/RestoreTestCompleteness.java b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/RestoreTestCompleteness.java
index ca2d28b7166..092b37d7753 100644
--- a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/RestoreTestCompleteness.java
+++ b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/RestoreTestCompleteness.java
@@ -19,16 +19,12 @@
package org.apache.flink.table.planner.plan.nodes.exec.testutils;
import org.apache.flink.table.planner.plan.nodes.exec.ExecNode;
-import org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecGlobalWindowAggregate;
-import org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecLocalWindowAggregate;
-import org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecOverAggregate;
import org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecPythonCalc;
import org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecPythonCorrelate;
import org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecPythonGroupAggregate;
import org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecPythonGroupTableAggregate;
import org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecPythonGroupWindowAggregate;
import org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecPythonOverAggregate;
-import org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecWindowAggregate;
import org.apache.flink.table.planner.plan.utils.ExecNodeMetadataUtil;
import org.apache.flink.table.planner.plan.utils.ExecNodeMetadataUtil.ExecNodeNameVersion;
@@ -52,14 +48,6 @@ public class RestoreTestCompleteness {
private static final Set<Class<? extends ExecNode<?>>> SKIP_EXEC_NODES =
new HashSet<Class<? extends ExecNode<?>>>() {
{
- /** TODO: Remove after FLINK-33676 is merged. */
- add(StreamExecWindowAggregate.class);
- add(StreamExecLocalWindowAggregate.class);
- add(StreamExecGlobalWindowAggregate.class);
-
- /** TODO: Remove after FLINK-33805 is merged. */
- add(StreamExecOverAggregate.class);
-
/** Ignoring python based exec nodes temporarily. */
add(StreamExecPythonCalc.class);
add(StreamExecPythonCorrelate.class);