LiJie20190102 commented on PR #10416: URL: https://github.com/apache/seatunnel/pull/10416#issuecomment-3827217088
> @LiJie20190102 Hi, the relevant logic has been fully covered by existing tests, see: [PostgresCDCIT](https://github.com/apache/seatunnel/blob/dev/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-postgres-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/postgres/PostgresCDCIT.java#L330,) so no duplicate test cases are written. > > The original code logic has two issues: first, it will throw exceptions in Chinese OS because PostgreSQL's exception messages are automatically adapted to the system language, causing the relevant judgment to fail; second, the original logic itself is not rigorous and has potential risks. I have reviewed the relevant code of Flink CDC at `https://github.com/apache/flink-cdc/blob/release-3.5/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/PostgresScanFetchTask.java`. Is it possible to simply add `if (slotInfo == null)` instead of modifying `replicationConnection.createReplicationSlot().orElse(null)` <img width="809" height="515" alt="image" src="https://github.com/user-attachments/assets/26d640e2-bfde-48c2-aa32-2f369c2328ad"; /> -- 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]
