Update restore.go

pingcap · May 20, 2021 · 846569b · 846569b
1 parent ec770d4
commit 846569b
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/pkg/lightning/restore/restore.go b/pkg/lightning/restore/restore.go
@@ -2648,10 +2648,6 @@ func (cr *chunkRestore) encodeLoop(
 				canDeliver = true
 				kvSize = 0
 			}
-
-			if len(kvPacket) >= maxKvPairsCnt || newOffset == cr.chunk.Chunk.EndOffset {
-				canDeliver = true
-			}
 		}
 		encodeTotalDur += encodeDur
 		metric.RowEncodeSecondsHistogram.Observe(encodeDur.Seconds())