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 54a9e112411 [FLINK-40892][table] Remove stale NDU IGNORE override from
changelog PTF semantic tests
54a9e112411 is described below
commit 54a9e112411e3aa49f690643280822281c7670f7
Author: Gustavo de Morais <[email protected]>
AuthorDate: Mon Oct 5 11:28:54 2026 +0200
[FLINK-40892][table] Remove stale NDU IGNORE override from changelog PTF
semantic tests
---
.../plan/nodes/exec/stream/FromChangelogSemanticTests.java | 10 ----------
.../plan/nodes/exec/stream/ToChangelogSemanticTests.java | 10 ----------
2 files changed, 20 deletions(-)
diff --git
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/FromChangelogSemanticTests.java
b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/FromChangelogSemanticTests.java
index 2892d22eda9..ac0901853fb 100644
---
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/FromChangelogSemanticTests.java
+++
b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/FromChangelogSemanticTests.java
@@ -18,8 +18,6 @@
package org.apache.flink.table.planner.plan.nodes.exec.stream;
-import org.apache.flink.table.api.TableConfig;
-import org.apache.flink.table.api.config.OptimizerConfigOptions;
import
org.apache.flink.table.planner.plan.nodes.exec.testutils.SemanticTestBase;
import org.apache.flink.table.test.program.TableTestProgram;
@@ -28,14 +26,6 @@ import java.util.List;
/** Semantic tests for the built-in FROM_CHANGELOG process table function. */
public class FromChangelogSemanticTests extends SemanticTestBase {
- @Override
- protected void applyDefaultEnvironmentOptions(TableConfig config) {
- super.applyDefaultEnvironmentOptions(config);
- config.set(
-
OptimizerConfigOptions.TABLE_OPTIMIZER_NONDETERMINISTIC_UPDATE_STRATEGY,
- OptimizerConfigOptions.NonDeterministicUpdateStrategy.IGNORE);
- }
-
@Override
public List<TableTestProgram> programs() {
return List.of(
diff --git
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/ToChangelogSemanticTests.java
b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/ToChangelogSemanticTests.java
index c35394c7694..24f248f01ce 100644
---
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/ToChangelogSemanticTests.java
+++
b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/ToChangelogSemanticTests.java
@@ -18,8 +18,6 @@
package org.apache.flink.table.planner.plan.nodes.exec.stream;
-import org.apache.flink.table.api.TableConfig;
-import org.apache.flink.table.api.config.OptimizerConfigOptions;
import
org.apache.flink.table.planner.plan.nodes.exec.testutils.SemanticTestBase;
import org.apache.flink.table.test.program.TableTestProgram;
@@ -28,14 +26,6 @@ import java.util.List;
/** Semantic tests for the built-in TO_CHANGELOG process table function. */
public class ToChangelogSemanticTests extends SemanticTestBase {
- @Override
- protected void applyDefaultEnvironmentOptions(TableConfig config) {
- super.applyDefaultEnvironmentOptions(config);
- config.set(
-
OptimizerConfigOptions.TABLE_OPTIMIZER_NONDETERMINISTIC_UPDATE_STRATEGY,
- OptimizerConfigOptions.NonDeterministicUpdateStrategy.IGNORE);
- }
-
@Override
public List<TableTestProgram> programs() {
return List.of(
