JNSimba commented on PR #4453: URL: https://github.com/apache/flink-cdc/pull/4453#issuecomment-4888421822
> From my perspective, connectorConfig.getSnapshotFetchSize() and scan.snapshot.fetch.size should match. I'm wondering if there might be a bug in the parameter conversion. This assumes that `scan.snapshot.fetch.size` is assigned to the Debezium properties during the `configbuild` phase; currently, this assignment is missing. Based on the approach used for MySQL, modifying this specific area would have the least impact. https://github.com/apache/flink-cdc/pull/2766/changes -- 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]
