diff --git a/oak-segment-azure/src/main/java/org/apache/jackrabbit/oak/segment/azure/queue/SegmentWriteQueue.java b/oak-segment-azure/src/main/java/org/apache/jackrabbit/oak/segment/azure/queue/SegmentWriteQueue.java index 86a7dbdf74..c297619345 100644 --- a/oak-segment-azure/src/main/java/org/apache/jackrabbit/oak/segment/azure/queue/SegmentWriteQueue.java +++ b/oak-segment-azure/src/main/java/org/apache/jackrabbit/oak/segment/azure/queue/SegmentWriteQueue.java @@ -168,6 +168,7 @@ public class SegmentWriteQueue implements Closeable { throw new IOException("Can't add segment to the queue"); } } catch (InterruptedException e) { + segmentsByUUID.remove(action.getUuid()); throw new IOException(e); } finally { flushLock.readLock().unlock();