Fix ci.

apache · Feb 19, 2024 · 3bef014 · 3bef014
1 parent 3b7ed48
commit 3bef014
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/...r-benchmark/src/main/java/org/apache/bookkeeper/benchmark/BenchReadThroughputLatency.java b/...r-benchmark/src/main/java/org/apache/bookkeeper/benchmark/BenchReadThroughputLatency.java
@@ -114,6 +114,7 @@ private static void readLedger(ClientConfiguration conf, long ledgerId, byte[] p
                     while (entries.hasMoreElements()) {
                         LedgerEntry e = entries.nextElement();
                         entriesRead++;
+                        lastRead = e.getEntryId();
                         if ((entriesRead % 10000) == 0) {
                             LOG.info("{} entries read from ledger {}", entriesRead, ledgerId);
                         }

diff --git a/bookkeeper-server/src/test/java/org/apache/bookkeeper/client/BookKeeperTest.java b/bookkeeper-server/src/test/java/org/apache/bookkeeper/client/BookKeeperTest.java
@@ -629,7 +629,7 @@ public void testBatchReadFailBackToSingleRead1() throws Exception {
                 }
                 try (LedgerHandle lh = bkc.openLedger(ledgerId, digestType, "testPasswd".getBytes())) {
                     assertEquals(numEntries - 1, lh.readLastConfirmed());
-                    //V2 protocol not support batch read. In theory, it will throw UnsupportedOperationException.
+                    //V3 protocol not support batch read. In theory, it will throw UnsupportedOperationException.
                     try {
                         lh.batchReadEntries(0, numEntries, 5 * 1024 * 1024);
                         fail("Should throw UnsupportedOperationException.");
@@ -684,7 +684,7 @@ public void testBatchReadFailBackToSingleRead2() throws Exception {
                 }
                 try (LedgerHandle lh = bkc.openLedger(ledgerId, digestType, "testPasswd".getBytes())) {
                     assertEquals(numEntries - 1, lh.readLastConfirmed());
-                    //V2 protocol not support batch read, it will throw UnsupportedOperationException.
+                    //V3 protocol not support batch read, it will throw UnsupportedOperationException.
                     try {
                         lh.batchReadEntries(0, numEntries, 5 * 1024 * 1024);
                         fail("Should throw UnsupportedOperationException.");