QuakeWang opened a new pull request, #8093:
URL: https://github.com/apache/paimon/pull/8093
### Purpose
`TableAwareFileStoreSourceSplit` extends `FileStoreSourceSplit`, but it
inherited `updateWithRecordsToSkip` from the parent class. During reader
checkpointing, `FileStoreSourceSplitState.toSourceSplit()` calls that method
and returned a plain `FileStoreSourceSplit`, dropping the CDC table metadata
and causing CDC reader state restoration to cast the split back to
`TableAwareFileStoreSourceSplit`.
This PR overrides `updateWithRecordsToSkip` in
`TableAwareFileStoreSourceSplit` so checkpointed active splits keep their
table-aware type and preserve `identifier`, `lastSchemaId`, and `schemaId`.
### Tests
- `mvn -pl paimon-flink/paimon-flink-cdc -am -DfailIfNoTests=false
-Dtest=TableAwareFileStoreSourceSplitSerializerTest test`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
