You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/12/04 10:05:00 UTC

[jira] [Created] (FLINK-38780) Potential State Incompatibility Issue in Paimon Sink

Yanquan Lv created FLINK-38780:
----------------------------------

             Summary: Potential State Incompatibility Issue in Paimon Sink
                 Key: FLINK-38780
                 URL: https://issues.apache.org/jira/browse/FLINK-38780
             Project: Flink
          Issue Type: Bug
          Components: Flink CDC
            Reporter: Yanquan Lv
            Assignee: Yanquan Lv


*In the current state recovery scenario, Paimon Sink assumes that a non-null state must exist (see [[reference|https://github.com/apache/flink-cdc/blob/8edc345b1a1cc34d542bc9ca69c30ae1082bbf18/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSink.java#L88]|https://github.com/apache/flink-cdc/blob/8edc345b1a1cc34d542bc9ca69c30ae1082bbf18/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSink.java#L88]).* 

*This assumption is incorrect when upgrading from a lower version of FlinkCDC to a higher version.*



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