From db90916453bdbc78812f041ab1dbd184a02423c2 Mon Sep 17 00:00:00 2001 From: Arka Ganguli Date: Sun, 12 Apr 2020 15:54:14 -0700 Subject: [PATCH] update query counts for stream queries from vtgate Signed-off-by: Arka Ganguli --- go/vt/vtgate/executor.go | 1 + 1 file changed, 1 insertion(+) diff --git a/go/vt/vtgate/executor.go b/go/vt/vtgate/executor.go index ef123ae2ff3..f29bacc5f2c 100644 --- a/go/vt/vtgate/executor.go +++ b/go/vt/vtgate/executor.go @@ -1267,6 +1267,7 @@ func (e *Executor) StreamExecute(ctx context.Context, method string, safeSession } logStats.ExecuteTime = time.Since(execStart) + e.updateQueryCounts(plan.Instructions.RouteType(), plan.Instructions.GetKeyspaceName(), plan.Instructions.GetTableName(), int64(logStats.ShardQueries)) return err }