diff --git a/app/vminsert/netstorage/netstorage.go b/app/vminsert/netstorage/netstorage.go index fe29367626..5a000530b8 100644 --- a/app/vminsert/netstorage/netstorage.go +++ b/app/vminsert/netstorage/netstorage.go @@ -167,6 +167,9 @@ func (sn *storageNode) dial() error { } func (sn *storageNode) closeBrokenConn() { + if sn.bc == nil { + return + } _ = sn.bc.Close() sn.bc = nil sn.connectionErrors.Inc()