polish

Signed-off-by: Ping Yu <[email protected]>
tikv · Mar 4, 2024 · dd9620a · dd9620a
1 parent 02b5646
commit dd9620a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/cdc/cdc/sink/tikv.go b/cdc/cdc/sink/tikv.go
@@ -434,7 +434,9 @@ func (k *tikvSink) runWorker(ctx context.Context, workerIdx uint32) error {
 			}
 			continue
 		}
-		_ = batcher.Append(e.rawKVEntry) // TODO: handle error
+		if err := batcher.Append(e.rawKVEntry); err != nil {
+			return errors.Trace(err)
+		}
 
 		if batcher.ByteSize() >= defaultTiKVBatchBytesLimit {
 			if err := flushToTiKV(); err != nil {