diff --git a/br/pkg/lightning/errormanager/errormanager.go b/br/pkg/lightning/errormanager/errormanager.go
index e8e31a51887c2..43921345b9433 100644
--- a/br/pkg/lightning/errormanager/errormanager.go
+++ b/br/pkg/lightning/errormanager/errormanager.go
@@ -794,7 +794,9 @@ func (em *ErrorManager) ResolveConflictKeysError(
 		if err := kvRows.Scan(&kvRowsCount); err != nil {
 			return errors.Trace(err)
 		}
-
+	}
+	if err := kvRows.Err(); err != nil {
+		return errors.Trace(err)
 	}
 
 	em.logger.Debug("got kv rows count from table",
@@ -817,6 +819,9 @@ func (em *ErrorManager) ResolveConflictKeysError(
 				logutil.Key("raw_key", rawKey),
 				zap.Binary("raw_row", rawRow))
 		}
+		if err := rows.Err(); err != nil {
+			return errors.Trace(err)
+		}
 		return common.ErrFoundDuplicateKeys.FastGenByArgs(rawKey, rawRow)
 	}
 	return nil