(flink) branch master updated: [FLINK-40013][table] Correctly clear state in ctx.clearState in ProcessTableFunctionTestHarness (#28574)

[fhueske]

This is an automated email from the ASF dual-hosted git repository.

fhueske 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 291f68a5e0b [FLINK-40013][table] Correctly clear state in 
ctx.clearState in ProcessTableFunctionTestHarness (#28574)
291f68a5e0b is described below

commit 291f68a5e0bb2b54085869a77cd6ab9bbdd39f78
Author: Mika Naylor <mnay...@confluent.io>
AuthorDate: Tue Jun 30 11:22:23 2026 +0200

    [FLINK-40013][table] Correctly clear state in ctx.clearState in 
ProcessTableFunctionTestHarness (#28574)
---
 .../flink/table/runtime/functions/TestHarnessStateManager.java       | 5 ++++-
 .../table/runtime/functions/ProcessTableFunctionTestHarnessTest.java | 3 ---
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/flink-table/flink-table-test-utils/src/main/java/org/apache/flink/table/runtime/functions/TestHarnessStateManager.java
 
b/flink-table/flink-table-test-utils/src/main/java/org/apache/flink/table/runtime/functions/TestHarnessStateManager.java
index 35f18caa611..20a9c800fd2 100644
--- 
a/flink-table/flink-table-test-utils/src/main/java/org/apache/flink/table/runtime/functions/TestHarnessStateManager.java
+++ 
b/flink-table/flink-table-test-utils/src/main/java/org/apache/flink/table/runtime/functions/TestHarnessStateManager.java
@@ -124,7 +124,10 @@ class TestHarnessStateManager {
         Map<String, Object> internalState = new HashMap<>();
         for (ProcessTableFunctionTestHarness.StateArgumentInfo stateArg : 
stateArguments) {
             Object external = externalState.get(stateArg.name);
-            Object internalData = convertToInternal(external, stateArg);
+            Object internalData =
+                    external == null
+                            ? createNewStateInternalData(stateArg)
+                            : convertToInternal(external, stateArg);
             internalState.put(stateArg.name, internalData);
         }
         stateByKey.put(key, internalState);
diff --git 
a/flink-table/flink-table-test-utils/src/test/java/org/apache/flink/table/runtime/functions/ProcessTableFunctionTestHarnessTest.java
 
b/flink-table/flink-table-test-utils/src/test/java/org/apache/flink/table/runtime/functions/ProcessTableFunctionTestHarnessTest.java
index 9fa8828d8f9..b2ab499ca2c 100644
--- 
a/flink-table/flink-table-test-utils/src/test/java/org/apache/flink/table/runtime/functions/ProcessTableFunctionTestHarnessTest.java
+++ 
b/flink-table/flink-table-test-utils/src/test/java/org/apache/flink/table/runtime/functions/ProcessTableFunctionTestHarnessTest.java
@@ -1918,9 +1918,6 @@ class ProcessTableFunctionTestHarnessTest {
                         Row input) {
             String action = input.getFieldAs("action");
             if ("increment".equals(action)) {
-                if (state == null) {
-                    state = new CounterState();
-                }
                 state.count++;
                 collect(Row.of("count=" + state.count));
             } else if ("clear-state".equals(action)) {