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)
