diff --git a/go/vt/binlog/binlogplayer/dbclient.go b/go/vt/binlog/binlogplayer/dbclient.go
index 2485ef08b2d..ce2ccaccb17 100644
--- 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
index 1d50dd93a6f..9ecf8669d6d 100644
--- 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