Skip to content

Commit d12e08a

Browse files
liaoxiaorongsiddontang
authored andcommitted
log unkonw stream header instead quit (go-mysql-org#108)
1 parent 9f867b4 commit d12e08a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

replication/binlogsyncer.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -529,8 +529,8 @@ func (b *BinlogSyncer) onStream(s *BinlogStreamer) {
529529
log.Info("receive EOF packet, retry ReadPacket")
530530
continue
531531
default:
532-
s.closeWithError(fmt.Errorf("invalid stream header %c", data[0]))
533-
return
532+
log.Errorf("invalid stream header %c", data[0])
533+
continue
534534
}
535535
}
536536
}

0 commit comments

Comments
 (0)