[FLINK-35813][runtime] Do not clear state field in TSO until operat…

…or was closed
apache · Jul 11, 2024 · e469e95 · e469e95
1 parent 302a691
commit e469e95
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...c/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformSchemaOperator.java b/...c/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformSchemaOperator.java
@@ -159,6 +159,7 @@ public void finish() throws Exception {
     public void close() throws Exception {
         super.close();
         clearOperator();
+        this.state = null;
     }
 
     @Override
@@ -292,6 +293,5 @@ private DataChangeEvent processProjection(
     private void clearOperator() {
         this.transforms = null;
         this.processorMap = null;
-        this.state = null;
     }
 }