fix comments

pingcap · Apr 6, 2023 · c0dbaee · c0dbaee
1 parent 85801b9
commit c0dbaee
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/executor/importer/chunk_process.go b/executor/importer/chunk_process.go
@@ -83,7 +83,7 @@ func (b *deliverKVBatch) size() uint64 {
 
 func (b *deliverKVBatch) add(kvs *kv.Pairs) {
 	for _, pair := range kvs.Pairs {
-		if pair.Key[tablecodec.TableSplitKeyLen+1] == 'r' {
+		if tablecodec.IsRecordKey(pair.Key) {
 			b.dataKVs.Pairs = append(b.dataKVs.Pairs, pair)
 			b.dataChecksum.UpdateOne(pair)
 		} else {
@@ -123,6 +123,7 @@ type chunkProcessor struct {
 }
 
 func (p *chunkProcessor) process(ctx context.Context) error {
+	// todo: use error group pattern to simplify the code
 	deliverCompleteCh := make(chan deliverResult)
 	go func() {
 		defer close(deliverCompleteCh)