diff --git a/qdb/etcdqdb.go b/qdb/etcdqdb.go index e28aa4323..2cbb3c787 100644 --- a/qdb/etcdqdb.go +++ b/qdb/etcdqdb.go @@ -521,6 +521,10 @@ func (q *EtcdQDB) TryCoordinatorLock(ctx context.Context) error { } if !stat.Succeeded { + _, err := q.cli.Lease.Revoke(ctx, leaseGrantResp.ID) + if err != nil { + return err + } return spqrerror.New(spqrerror.SPQR_UNEXPECTED, "qdb is already in use") }