fix ignoring error

Signed-off-by: hillium <[email protected]>
pingcap · Dec 20, 2024 · c1d7800 · c1d7800
1 parent b8ef140
commit c1d7800
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/br/pkg/task/operator/checksum_table.go b/br/pkg/task/operator/checksum_table.go
@@ -245,6 +245,9 @@ func (c *checksumTableCtx) runChecksum(ctx context.Context, reqs []request) ([]C
 					zap.Int64("total", int64(total)),
 				)
 			})
+			if err != nil {
+				return err
+			}
 			res := ChecksumResult{
 				DBName:    req.dbName,
 				TableName: req.tableName,
@@ -256,7 +259,7 @@ func (c *checksumTableCtx) runChecksum(ctx context.Context, reqs []request) ([]C
 			resultsMu.Lock()
 			results = append(results, res)
 			resultsMu.Unlock()
-			return err
+			return nil
 		})
 	}