Can't stop nitting...

Signed-off-by: Matt Lord <[email protected]>
vitessio · Dec 5, 2023 · d15fb0b · d15fb0b
1 parent 5747049
commit d15fb0b
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/go/vt/binlog/binlogplayer/dbclient.go b/go/vt/binlog/binlogplayer/dbclient.go
@@ -158,7 +158,6 @@ func (dc *dbClientImpl) ExecuteFetchMulti(query string, maxrows int) ([]*sqltype
 		}
 		results = append(results, mqr)
 	}
-
 	return results, nil
 }
 

diff --git a/go/vt/vttablet/tabletmanager/vreplication/replicator_plan.go b/go/vt/vttablet/tabletmanager/vreplication/replicator_plan.go
@@ -478,7 +478,6 @@ func (tp *TablePlan) applyBulkDeleteChanges(rowDeletes []*binlogdatapb.RowChange
 		if err != nil {
 			return nil, err
 		}
-		querySize = baseQuerySize
 		tp.TablePlanBuilder.stats.BulkQueryCount.Add("delete", 1)
 		return executor(query)
 	}
@@ -501,6 +500,7 @@ func (tp *TablePlan) applyBulkDeleteChanges(rowDeletes []*binlogdatapb.RowChange
 				return nil, err
 			}
 			pkVals = nil
+			querySize = baseQuerySize
 		}
 		pkVals = append(pkVals, vals[pkIndex])
 		querySize += addedSize
-Original file line number
+Diff line change
@@ Expand Up @@
     		}
     		results = append(results, mqr)
     	}
     	return results, nil
     }
@@ Expand Down @@