[pulsar] 05/10: Print position info when can't find next valid position. (#11969)

[penghui]

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit 18b36d6cc8354a50f849e7e5fdbe893d9eeca1c7
Author: GuoJiwei <techno...@apache.org>
AuthorDate: Thu Sep 9 09:01:07 2021 +0800

    Print position info when can't find next valid position. (#11969)
    
    When the user reset the cursor and does not find the next valid one, the 
original log does'nt print position info.
    ```
    12:13:36.676 [pulsar-web-67-14] INFO  
org.apache.pulsar.broker.service.persistent.PersistentSubscription - 
[persistent://public/default/test][sub] Successfully disconnected consumers 
from subscription, proceeding with cursor reset
    12:13:36.676 [bookkeeper-ml-workers-OrderedExecutor-2-0] ERROR 
org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl - 
[public/default/persistent/test] Can't find next valid position, fail back to 
the next position of the last position.
    java.lang.NullPointerException: null
        at 
org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl.getNextValidPositionInternal(ManagedLedgerImpl.java:3031)
 ~[io.streamnative-managed-ledger-2.7.2.10.jar:2.7.2.10]
        at 
org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl.getNextValidPosition(ManagedLedgerImpl.java:3018)
 ~[io.streamnative-managed-ledger-2.7.2.10.jar:2.7.2.10]
        at 
org.apache.bookkeeper.mledger.impl.ManagedCursorImpl.lambda$asyncResetCursor$6(ManagedCursorImpl.java:1086)
 ~[io.streamnative-managed-ledger-2.7.2.10.jar:2.7.2.10]
        at 
org.apache.bookkeeper.mledger.util.SafeRun$1.safeRun(SafeRun.java:32) 
[io.streamnative-managed-ledger-2.7.2.10.jar:2.7.2.10]
        at 
org.apache.bookkeeper.common.util.SafeRunnable.run(SafeRunnable.java:36) 
[org.apache.bookkeeper-bookkeeper-common-4.12.0.jar:4.12.0]
        at 
org.apache.bookkeeper.common.util.OrderedExecutor$TimedRunnable.run(OrderedExecutor.java:203)
 [org.apache.bookkeeper-bookkeeper-common-4.12.0.jar:4.12.0]
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 
[?:1.8.0_281]
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 
[?:1.8.0_281]
        at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
 [io.netty-netty-common-4.1.60.Final.jar:4.1.60.Final]
        at java.lang.Thread.run(Thread.java:748) [?:1.8.0_281]
    ```
    
    So it's better to add position info to the log.
    
    (cherry picked from commit 3cd5b9ed3b59dd153b04ce4f6e61da377900f9be)
---
 .../java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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
index 760d261..20d749d 100644
--- 
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
@@ -3017,7 +3017,9 @@ public class ManagedLedgerImpl implements ManagedLedger, 
CreateCallback {
             next = getNextValidPositionInternal(position);
         } catch (NullPointerException e) {
             next = lastConfirmedEntry.getNext();
-            log.error("[{}] Can't find next valid position, fail back to the 
next position of the last position.", name, e);
+            if (log.isDebugEnabled()) {
+                log.debug("[{}] Can't find next valid position : {}, fall back 
to the next position of the last position : {}.", position, name, next, e);
+            }
         }
         return next;
     }