Update rowlog for the API change made for the vstream skew alignment …

…feature Signed-off-by: Rohit Nayak <rohit@planetscale.com>
vitessio · Apr 22, 2021 · a2a5d54 · a2a5d54
1 parent 889406d
commit a2a5d54
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/tools/rowlog/rowlog.go b/tools/rowlog/rowlog.go
@@ -12,6 +12,7 @@ import (
  "strings"
  "sync"
  "time"
+ vtgatepb "vitess.io/vitess/go/vt/proto/vtgate"
 
  "vitess.io/vitess/go/mysql"
  "vitess.io/vitess/go/sqltypes"
@@ -155,7 +156,7 @@ func startStreaming(ctx context.Context, vtgate, vtctld, keyspace, tablet, table
  log.Fatal(err)
  }
  defer conn.Close()
- reader, err := conn.VStream(ctx, topodatapb.TabletType_MASTER, vgtid, filter)
+ reader, err := conn.VStream(ctx, topodatapb.TabletType_MASTER, vgtid, filter, &vtgatepb.VStreamFlags{})
  var fields []*query.Field
  var gtid string
  var plan *TablePlan