Skip to content
This repository was archived by the owner on Feb 13, 2026. It is now read-only.

Commit 5a8e65c

Browse files
author
dfcao
committed
fix stop-never option
1 parent 42c6f53 commit 5a8e65c

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ UPDATE `test`.`test3` SET `addtime`='2016-12-10 13:03:22', `data`='中文', `id`
8888

8989
**解析模式**
9090

91-
--stop-never 持续解析binlog。可选。默认False,同步至执行命令时最新的binlog位置。
91+
--stop-never 持续解析binlog。可选。默认False,同步至执行命令时最新的binlog位置。
9292

9393
-K, --no-primary-key 对INSERT语句去除主键。可选。默认False
9494

binlog2sql/binlog2sql.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ def __init__(self, connection_settings, start_file=None, start_pos=None, end_fil
6464
def process_binlog(self):
6565
stream = BinLogStreamReader(connection_settings=self.conn_setting, server_id=self.server_id,
6666
log_file=self.start_file, log_pos=self.start_pos, only_schemas=self.only_schemas,
67-
only_tables=self.only_tables, resume_stream=True)
67+
only_tables=self.only_tables, resume_stream=True, blocking=True)
6868

6969
flag_last_event = False
7070
e_start_pos, last_pos = stream.log_pos, stream.log_pos

0 commit comments

Comments
 (0)