We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 022cd15 + 25c9766 commit 6b51b98Copy full SHA for 6b51b98
pymysqlreplication/binlogstream.py
@@ -554,7 +554,8 @@ def fetchone(self):
554
# invalidates all our cached table id to schema mappings. This means we have to load them all
555
# again for each logfile which is potentially wasted effort but we can't really do much better
556
# without being broken in restart case
557
- self.table_map = {}
+ if binlog_event.timestamp != 0:
558
+ self.table_map = {}
559
elif binlog_event.log_pos:
560
self.log_pos = binlog_event.log_pos
561
0 commit comments