[pulsar-broker] add valid-readPosition check before setting readPosit…

…ion at cursor (apache#3881) * [pulsar-broker] add valid-readPosition check before setting readPosition at cursor * fix test
XiaoMaoGuai · May 18, 2019 · a207645 · a207645
1 parent 831476b
commit a207645
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java
@@ -1963,8 +1963,10 @@ public void asyncClose(final AsyncCallbacks.CloseCallback callback, final Object
      */
     void setReadPosition(Position newReadPositionInt) {
         checkArgument(newReadPositionInt instanceof PositionImpl);
-
-        this.readPosition = (PositionImpl) newReadPositionInt;
+        if (this.markDeletePosition == null
+                || ((PositionImpl) newReadPositionInt).compareTo(this.markDeletePosition) > 0) {
+            this.readPosition = (PositionImpl) newReadPositionInt;
+        }
     }
 
     // //////////////////////////////////////////////////