diff --git a/go/test/endtoend/reparent/utils_test.go b/go/test/endtoend/reparent/utils_test.go index fa97ebef4f8..44bf8ec918f 100644 --- a/go/test/endtoend/reparent/utils_test.go +++ b/go/test/endtoend/reparent/utils_test.go @@ -116,6 +116,7 @@ func setupCluster(ctx context.Context, t *testing.T, shardName string, cells []s clusterInstance.VtTabletExtraArgs = []string{ "-lock_tables_timeout", "5s", "-enable_semi_sync", + "-init_populate_metadata", "-track_schema_versions=true", } diff --git a/go/vt/vttablet/tabletmanager/tm_state.go b/go/vt/vttablet/tabletmanager/tm_state.go index be10b40db60..124b9f020e2 100644 --- a/go/vt/vttablet/tabletmanager/tm_state.go +++ b/go/vt/vttablet/tabletmanager/tm_state.go @@ -239,7 +239,6 @@ func (ts *tmState) updateLocked(ctx context.Context) { // before other services are shutdown. reason := ts.canServe(ts.tablet.Type) if reason != "" { - ts.populateLocalMetadataLocked() log.Infof("Disabling query service: %v", reason) if err := ts.tm.QueryServiceControl.SetServingType(ts.tablet.Type, terTime, false, reason); err != nil { log.Errorf("SetServingType(serving=false) failed: %v", err) @@ -281,8 +280,6 @@ func (ts *tmState) updateLocked(ctx context.Context) { if err := ts.tm.QueryServiceControl.SetServingType(ts.tablet.Type, terTime, true, ""); err != nil { log.Errorf("Cannot start query service: %v", err) } - - ts.populateLocalMetadataLocked() } }