[jira] [Created] (FLINK-35813) Transform schema operator failed to trigger checkpoint with bounded source

[yux (Jira)]

yux created FLINK-35813:
---------------------------

             Summary: Transform schema operator failed to trigger checkpoint 
with bounded source
                 Key: FLINK-35813
                 URL: https://issues.apache.org/jira/browse/FLINK-35813
             Project: Flink
          Issue Type: Improvement
          Components: Flink CDC
            Reporter: yux


Currently, transform schema operator clears its state field after a bounded job 
finishes. Any following checkpoint requests in snapshotState method will cause 
an NPE. Here's a minimum reproducible example:

```
source:
  type: values
sink:
  type: values
transform:
   ...
```



--
This message was sent by Atlassian Jira
(v8.20.10#820010)