fix: return error 'meet unexepted binlog event type' on binlog end wi…

…th ROTATE_EVENT etc.
xiezhenye · Aug 28, 2015 · 05abd9c · 05abd9c
1 parent f491e67
commit 05abd9c
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/binlog_undo.cc b/src/binlog_undo.cc
@@ -99,6 +99,10 @@ Result BinlogUndo::scan_begin()
     result = read_event_header_at(current_header.log_pos);
     ASSERT_BU_OK(result);
   }
+  if (current_header.type_code == ROTATE_EVENT ||
+      current_header.type_code == STOP_EVENT) {
+    return BU_EOF;
+  }
   if (current_header.type_code != QUERY_EVENT || current_header.data_written > 100) { // much bigger than begin event(79)
     return BU_UNEXCEPTED_EVENT_TYPE;
   }