You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2024/03/27 12:27:50 UTC
(pulsar) branch branch-3.2 updated (c01f72ef1d0 -> 139fa304ebe)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-3.2
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from c01f72ef1d0 [fix][client] Consumer lost message ack due to race condition in acknowledge with batch message (#22353)
new a40d28b2c47 [fix] [test] Fix flaky test ManagedLedgerTest.testGetNumberOfEntriesInStorage (#22344)
new 139fa304ebe [fix][test] Fix flaky ManagedLedgerErrorsTest.recoverAfterZnodeVersionError (#22368)
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/bookkeeper/mledger/impl/ManagedLedgerErrorsTest.java | 1 -
.../org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java | 8 ++++----
2 files changed, 4 insertions(+), 5 deletions(-)
(pulsar) 01/02: [fix] [test] Fix flaky test ManagedLedgerTest.testGetNumberOfEntriesInStorage (#22344)
Posted by lh...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-3.2
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit a40d28b2c4796e231c324bef94a80dae27cc5ac4
Author: fengyubiao <yu...@streamnative.io>
AuthorDate: Wed Mar 27 16:45:02 2024 +0800
[fix] [test] Fix flaky test ManagedLedgerTest.testGetNumberOfEntriesInStorage (#22344)
(cherry picked from commit fc066d727b52f7e412476297995c2eb2f5ab61bf)
---
.../org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java
index 4c92911c687..264a2907969 100644
--- a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java
+++ b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java
@@ -2637,10 +2637,10 @@ public class ManagedLedgerTest extends MockedBookKeeperTestCase {
managedLedger.addEntry(("entry-" + i).getBytes(Encoding));
}
- //trigger ledger rollover and wait for the new ledger created
- Field stateUpdater = ManagedLedgerImpl.class.getDeclaredField("state");
- stateUpdater.setAccessible(true);
- stateUpdater.set(managedLedger, ManagedLedgerImpl.State.LedgerOpened);
+ // trigger ledger rollover and wait for the new ledger created
+ Awaitility.await().untilAsserted(() -> {
+ assertEquals("LedgerOpened", WhiteboxImpl.getInternalState(managedLedger, "state").toString());
+ });
managedLedger.rollCurrentLedgerIfFull();
Awaitility.await().untilAsserted(() -> {
assertEquals(managedLedger.getLedgersInfo().size(), 3);
(pulsar) 02/02: [fix][test] Fix flaky ManagedLedgerErrorsTest.recoverAfterZnodeVersionError (#22368)
Posted by lh...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-3.2
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 139fa304ebeabf1e1f645b23be6eaf92773fcbf4
Author: Lari Hotari <lh...@users.noreply.github.com>
AuthorDate: Wed Mar 27 04:10:47 2024 -0700
[fix][test] Fix flaky ManagedLedgerErrorsTest.recoverAfterZnodeVersionError (#22368)
(cherry picked from commit c184209bfc5a61f143abfa701e5f1b0be2109d77)
---
.../java/org/apache/bookkeeper/mledger/impl/ManagedLedgerErrorsTest.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerErrorsTest.java b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerErrorsTest.java
index 512e90d17f5..7b2f8228ad7 100644
--- a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerErrorsTest.java
+++ b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerErrorsTest.java
@@ -381,7 +381,6 @@ public class ManagedLedgerErrorsTest extends MockedBookKeeperTestCase {
ledger.addEntry("entry".getBytes());
fail("should fail");
} catch (ManagedLedgerFencedException e) {
- assertEquals(e.getCause().getClass(), ManagedLedgerException.BadVersionException.class);
// ok
}