Sync sequence like MySQL does

pingcap · Nov 2, 2023 · ee66779 · ee66779
1 parent 38bfe26
commit ee66779
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/server/internal/packetio.go b/pkg/server/internal/packetio.go
@@ -303,6 +303,10 @@ func (p *PacketIO) Flush() error {
 	if err != nil {
 		return errors.Trace(err)
 	}
+
+	if p.compressionAlgorithm != mysql.CompressionNone {
+		p.sequence = p.compressedSequence
+	}
 	return err
 }