remove unnecessary code

apache · Apr 14, 2023 · 84691ea · 84691ea
1 parent 0639929
commit 84691ea
Showing 1 changed file with 0 additions and 7 deletions.
diff --git a/...r/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java b/...r/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java
@@ -581,12 +581,6 @@ public synchronized NavigableSet<PositionImpl> getScheduledMessages(int maxMessa
                     break;
                 }
 
-                if (bucket.currentSegmentEntryId == bucket.lastSegmentEntryId) {
-                    immutableBuckets.asMapOfRanges().remove(Range.closed(bucket.startLedgerId, bucket.endLedgerId));
-                    bucket.asyncDeleteBucketSnapshot(stats);
-                    continue;
-                }
-
                 long loadStartTime = System.currentTimeMillis();
                 stats.recordTriggerEvent(BucketDelayedMessageIndexStats.Type.load);
                 CompletableFuture<Void> loadFuture = pendingLoad = bucket.asyncLoadNextBucketSnapshotEntry()
@@ -636,7 +630,6 @@ public synchronized NavigableSet<PositionImpl> getScheduledMessages(int maxMessa
                     break;
                 }
             }
-            snapshotSegmentLastIndexTable.remove(ledgerId, entryId);
 
             positions.add(new PositionImpl(ledgerId, entryId));