Update restore.go

pingcap · May 20, 2021 · 00be7d0 · 00be7d0
1 parent 66ba74e
commit 00be7d0
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/pkg/lightning/restore/restore.go b/pkg/lightning/restore/restore.go
@@ -2566,10 +2566,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())