diff --git a/qdb/etcdqdb.go b/qdb/etcdqdb.go index e28aa4323..2195b39d9 100644 --- a/qdb/etcdqdb.go +++ b/qdb/etcdqdb.go @@ -521,6 +521,7 @@ func (q *EtcdQDB) TryCoordinatorLock(ctx context.Context) error { } if !stat.Succeeded { + _ = q.cli.Lease.Close() return spqrerror.New(spqrerror.SPQR_UNEXPECTED, "qdb is already in use") }