diff --git a/catalog/mvcc/cataloger_merge.go b/catalog/mvcc/cataloger_merge.go
index cfb4054041f..10942345e05 100644
--- a/catalog/mvcc/cataloger_merge.go
+++ b/catalog/mvcc/cataloger_merge.go
@@ -128,7 +128,9 @@ func (c *cataloger) doMerge(ctx context.Context, tx db.Tx, params doDiffParams,
 				}
 			}
 		case err := <-errChan:
-			return rowsCounter, err
+			if err != nil {
+				return rowsCounter, err
+			}
 		}
 	}
 }