DBZ-8140 Validate log position method missing gtid info from SourceInfo

This commit is contained in:
harveyyue 2024-08-13 14:56:25 +08:00 committed by Chris Cranford
parent 8ca16ee452
commit 4f500b60e2

View File

@ -170,6 +170,7 @@ public void setBinlogStartPoint(String binlogFilename, long positionOfFirstEvent
* have been previously processed
*/
public void setCompletedGtidSet(String gtidSet) {
sourceInfo.startGtid(gtidSet);
if (gtidSet != null && !gtidSet.trim().isEmpty()) {
// Remove all the newline chars that exist in the GTID set string ...
String trimmedGtidSet = gtidSet.replace("\n", "").replace("\r", "");