Introduce Position::resetPendingGTID()

ClickHouse · Nov 29, 2023 · d503eec · d503eec
1 parent 9e82b61
commit d503eec
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/Core/MySQL/MySQLReplication.h b/src/Core/MySQL/MySQLReplication.h
@@ -528,6 +528,7 @@ namespace MySQLReplication
         void update(BinlogEventPtr event);
         void update(UInt64 binlog_pos_, const String & binlog_name_, const String & gtid_sets_, UInt32 binlog_time_);
         void dump(WriteBuffer & out) const;
+        void resetPendingGTID() { pending_gtid.reset(); }
 
     private:
         std::optional<GTID> pending_gtid;