(flink-cdc) branch master updated: [FLINK-35813][cdc-runtime] Do not clear state field in TransformSchemaOperator until operator closed

[leonard]

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

leonard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git


The following commit(s) were added to refs/heads/master by this push:
     new 44dafe33b [FLINK-35813][cdc-runtime] Do not clear state field in 
TransformSchemaOperator  until operator closed
44dafe33b is described below

commit 44dafe33bd8c3cea15414b30eef4927e32bc8f37
Author: yuxiqian <34335406+yuxiq...@users.noreply.github.com>
AuthorDate: Tue Aug 6 17:49:16 2024 +0800

    [FLINK-35813][cdc-runtime] Do not clear state field in 
TransformSchemaOperator  until operator closed
    
    This closes #3469.
---
 .../flink/cdc/runtime/operators/transform/TransformSchemaOperator.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformSchemaOperator.java
 
b/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformSchemaOperator.java
index 230fc1a6f..ca8949ed6 100644
--- 
a/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformSchemaOperator.java
+++ 
b/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformSchemaOperator.java
@@ -159,6 +159,7 @@ public class TransformSchemaOperator extends 
AbstractStreamOperator<Event>
     public void close() throws Exception {
         super.close();
         clearOperator();
+        this.state = null;
     }
 
     @Override
@@ -292,6 +293,5 @@ public class TransformSchemaOperator extends 
AbstractStreamOperator<Event>
     private void clearOperator() {
         this.transforms = null;
         this.processorMap = null;
-        this.state = null;
     }
 }