We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 022cd15 commit 25c9766Copy full SHA for 25c9766
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