Merge pull request #7809 from planetscale/rn-rowlog-fix

Rowlog: Update rowlog for the API change made for the vstream skew alignment feature
vitessio · Apr 13, 2021 · 28a5321 · 28a5321
2 parents b999be8 + bf47abd
commit 28a5321
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