Skip to content

Commit

Permalink
Minor changes after self review
Browse files Browse the repository at this point in the history
Signed-off-by: Matt Lord <mattalord@gmail.com>
  • Loading branch information
mattlord committed Feb 7, 2024
1 parent 7709300 commit 84a2ef2
Showing 1 changed file with 0 additions and 4 deletions.
4 changes: 0 additions & 4 deletions go/vt/vtctl/workflow/resharder.go
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,6 @@ import (
"vitess.io/vitess/go/sqltypes"
"vitess.io/vitess/go/vt/concurrency"
"vitess.io/vitess/go/vt/key"
"vitess.io/vitess/go/vt/log"
"vitess.io/vitess/go/vt/schema"
"vitess.io/vitess/go/vt/topo"
"vitess.io/vitess/go/vt/topotools"
Expand Down Expand Up @@ -309,16 +308,13 @@ func (rs *resharder) createStreams(ctx context.Context) error {
}

for _, rstream := range rs.refStreams {
log.Errorf("DEBUG: Before AddRow: %s", rstream.bls.String())
ig.AddRow(rstream.workflow, rstream.bls, "", rstream.cell, rstream.tabletTypes,
// TODO: fix based on original stream.
binlogdatapb.VReplicationWorkflowType_Reshard,
binlogdatapb.VReplicationWorkflowSubType_None,
rs.deferSecondaryKeys)
log.Errorf("DEBUG: After AddRow: %s", rstream.bls.String())
}
query := ig.String()
log.Errorf("DEBUG: Full statement: %s", query)
if _, err := rs.s.tmc.VReplicationExec(ctx, targetPrimary.Tablet, query); err != nil {
return vterrors.Wrapf(err, "VReplicationExec(%v, %s)", targetPrimary.Tablet, query)
}
Expand Down

0 comments on commit 84a2ef2

Please sign in to comment.