From a2a5d5436aa54677b027e39f1884baf7f2610b5e Mon Sep 17 00:00:00 2001 From: Rohit Nayak Date: Thu, 8 Apr 2021 15:46:27 +0200 Subject: [PATCH] Update rowlog for the API change made for the vstream skew alignment feature Signed-off-by: Rohit Nayak --- tools/rowlog/rowlog.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/tools/rowlog/rowlog.go b/tools/rowlog/rowlog.go index f90a6a48a44..e4458005f4d 100644 --- 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