Fixing an issue of initializing table map when fake rotate event catc…

…hing for Mysql versions 5.5, 5.6, 5.7
julien-duponchelle · Oct 3, 2024 · 25c9766 · 25c9766
1 parent 022cd15
commit 25c9766
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pymysqlreplication/binlogstream.py b/pymysqlreplication/binlogstream.py
@@ -554,7 +554,8 @@ def fetchone(self):
                 # invalidates all our cached table id to schema mappings. This means we have to load them all
                 # again for each logfile which is potentially wasted effort but we can't really do much better
                 # without being broken in restart case
-                self.table_map = {}
+                if binlog_event.timestamp != 0:
+                    self.table_map = {}
             elif binlog_event.log_pos:
                 self.log_pos = binlog_event.log_pos