fix: missing update _next_seq_no

xiezhenye · xiezhenye · commit 12fa276065a3 · 2016-01-22T15:46:37.000+08:00
diff --git a/pymysqlreplication/binlogstream.py b/pymysqlreplication/binlogstream.py
@@ -226,6 +226,7 @@ def __connect_to_stream(self):
             self._stream_connection.wfile.flush()
         else:
             self._stream_connection._write_bytes(prelude)
+            self._stream_connection._next_seq_id = 1
         self.__connected_stream = True
 
     def fetchone(self):
