diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandle.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandle.java index 48818bd2f5b..661499e96cb 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandle.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandle.java @@ -685,8 +685,8 @@ public void asyncReadEntries(long firstEntry, long lastEntry, ReadCallback cb, O } if (lastEntry > lastAddConfirmed) { - LOG.error("ReadException on ledgerId:{} firstEntry:{} lastEntry:{}", - ledgerId, firstEntry, lastEntry); + LOG.error("ReadEntries exception on ledgerId:{} firstEntry:{} lastEntry:{} lastAddConfirmed:{}", + ledgerId, firstEntry, lastEntry, lastAddConfirmed); cb.readComplete(BKException.Code.ReadException, this, null, ctx); return; } @@ -751,8 +751,8 @@ public CompletableFuture readAsync(long firstEntry, long lastEntr } if (lastEntry > lastAddConfirmed) { - LOG.error("ReadException on ledgerId:{} firstEntry:{} lastEntry:{}", - ledgerId, firstEntry, lastEntry); + LOG.error("ReadAsync exception on ledgerId:{} firstEntry:{} lastEntry:{} lastAddConfirmed:{}", + ledgerId, firstEntry, lastEntry, lastAddConfirmed); return FutureUtils.exception(new BKReadException()); } diff --git a/bookkeeper-server/src/test/java/org/apache/bookkeeper/client/MdcContextTest.java b/bookkeeper-server/src/test/java/org/apache/bookkeeper/client/MdcContextTest.java index 89b008836e0..d50dd96fe76 100644 --- a/bookkeeper-server/src/test/java/org/apache/bookkeeper/client/MdcContextTest.java +++ b/bookkeeper-server/src/test/java/org/apache/bookkeeper/client/MdcContextTest.java @@ -228,7 +228,7 @@ public void testReadEntryBeyondLac() throws Exception { } catch (BKException.BKReadException e) { // pass } - assertLogWithMdc("ledger_read_entry", "ReadException on ledgerId:0 firstEntry:100 lastEntry:100"); + assertLogWithMdc("ledger_read_entry", "ReadEntries exception on ledgerId:0 firstEntry:100 lastEntry:100"); } @Test @@ -245,7 +245,7 @@ public void testReadFromDeletedLedger() throws Exception { } catch (BKException.BKReadException e) { // pass } - assertLogWithMdc("ledger_read_entry", "ReadException on ledgerId:0 firstEntry:100 lastEntry:100"); + assertLogWithMdc("ledger_read_entry", "ReadEntries exception on ledgerId:0 firstEntry:100 lastEntry:100"); } }