From c2bea373afde81aa37f1b33cba8abe742210278a Mon Sep 17 00:00:00 2001 From: Harshit Gangal Date: Mon, 8 Jul 2024 12:53:20 +0530 Subject: [PATCH] wip Signed-off-by: Harshit Gangal --- go/vt/vttablet/tabletserver/health_streamer.go | 1 + go/vt/vttablet/tabletserver/tx_engine.go | 8 -------- 2 files changed, 1 insertion(+), 8 deletions(-) diff --git a/go/vt/vttablet/tabletserver/health_streamer.go b/go/vt/vttablet/tabletserver/health_streamer.go index 269e3daefd6..c91bdde6dd5 100644 --- a/go/vt/vttablet/tabletserver/health_streamer.go +++ b/go/vt/vttablet/tabletserver/health_streamer.go @@ -74,6 +74,7 @@ type healthStreamer struct { // isServingPrimary stores if this tablet is currently the serving primary or not. isServingPrimary bool + te *TxEngine se *schema.Engine history *history.History diff --git a/go/vt/vttablet/tabletserver/tx_engine.go b/go/vt/vttablet/tabletserver/tx_engine.go index 7e8ecc06a75..a010571ddab 100644 --- a/go/vt/vttablet/tabletserver/tx_engine.go +++ b/go/vt/vttablet/tabletserver/tx_engine.go @@ -480,14 +480,6 @@ func (te *TxEngine) startWatchdog() { return } - coordConn, err := vtgateconn.Dial(ctx, te.coordinatorAddress) - if err != nil { - te.env.Stats().InternalErrors.Add("WatchdogFail", 1) - log.Errorf("Error connecting to coordinator '%v': %v", te.coordinatorAddress, err) - return - } - defer coordConn.Close() - var wg sync.WaitGroup for tx := range txs { wg.Add(1)