olivier-derom opened a new issue, #3108: URL: https://github.com/apache/flink-cdc/issues/3108
A majority of our Postgres databases use UUIDs as primary keys. When we enable 'scan.incremental.snapshot.enabled = true', Flink-CDC will try to split into chunks. The splitTableIntoChunks function relies on the queryMinMax function, which fails when trying to calculate the MIN(UUID), as that is not supported in Postgres. Is there a way around this? When we convert our column to VARCHAR, rather than UUID, everything seems to work. We did not find a way to cast our UUIDs to VARCHAR while splitting them into chunks without editing the source code or altering the source table. Disabling incremental snapshots also fixes the issue, as we do not split into chunks anymore, but this would mean we get a global read lock on the data before snapshot reading, which we want to avoid. Thanks in advance for the help! -- 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]
