fix code

dao-jun · Mar 9, 2024 · 7e41819 · 7e41819
1 parent dbcfffa
commit 7e41819
Showing 1 changed file with 5 additions and 13 deletions.
diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java
@@ -4547,22 +4547,14 @@ public void checkCursorsToCacheEntries() {
      * @param publishTime
      */
     protected void updatePublishTimestamp(long ledgerId, long publishTime) {
-        MutablePair<Long, Long> pair = ledgerPublishTimeMap.computeIfAbsent(ledgerId, k -> MutablePair.of(null, null));
-        Long start = pair.getLeft();
-        Long end = pair.getRight();
-        if (start == null) {
+        MutablePair<Long, Long> pair = ledgerPublishTimeMap.computeIfAbsent(ledgerId, k -> MutablePair.of(Long.MAX_VALUE, Long.MIN_VALUE));
+        long start = pair.getLeft();
+        long end = pair.getRight();
+        if (publishTime < start) {
             pair.setLeft(publishTime);
-        } else {
-            if (publishTime < start) {
-                pair.setLeft(publishTime);
-            }
         }
-        if (end == null) {
+        if (publishTime > end) {
             pair.setRight(publishTime);
-        } else {
-            if (publishTime > end) {
-                pair.setRight(publishTime);
-            }
         }
     }