wip

Signed-off-by: Harshit Gangal <harshit@planetscale.com>
vitessio · Jul 8, 2024 · c2bea37 · c2bea37
1 parent a8f689f
commit c2bea37
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 8 deletions.
diff --git 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
@@ -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)