We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9b5c1dc commit cba48b8Copy full SHA for cba48b8
pkg/kv/kvclient/kvcoord/txn_interceptor_write_buffer.go
@@ -1515,10 +1515,10 @@ func (rr requestRecord) toResp(
1515
// a lock, we add it to the buffer since we may need to flush it as
1516
// replicated lock.
1517
if rr.transformed {
1518
-
1519
transformedGetResponse := br.GetInner().(*kvpb.GetResponse)
1520
valueWasPresent := transformedGetResponse.Value.IsPresent()
1521
- lockShouldHaveBeenAcquired := valueWasPresent || req.LockNonExisting
+ lockShouldHaveBeenAcquired := (valueWasPresent || req.LockNonExisting) &&
+ transformedGetResponse.ResumeSpan != nil
1522
1523
if lockShouldHaveBeenAcquired {
1524
dla := &bufferedDurableLockAcquisition{
0 commit comments