You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2021/12/11 12:23:33 UTC
[pulsar] 01/10: fix flaky test in AdminApiOffloadTest (#11028)
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 bdb27c2f506966999994b74ad19af282b139520e
Author: hangc0276 <ch...@apache.org>
AuthorDate: Wed Jun 23 23:09:06 2021 +0800
fix flaky test in AdminApiOffloadTest (#11028)
(cherry picked from commit 1a80429c8ba12f0ce487d6fecbce62c3ca952e1a)
---
.../test/java/org/apache/pulsar/broker/admin/AdminApiOffloadTest.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiOffloadTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiOffloadTest.java
index 92ade37..19fb065 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiOffloadTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiOffloadTest.java
@@ -277,6 +277,8 @@ public class AdminApiOffloadTest extends MockedPulsarServiceBaseTest {
Map<NamespaceName, LedgerOffloader> map = new HashMap<>();
map.put(TopicName.get(topicName).getNamespaceObject(), namespaceOffloader);
doReturn(map).when(pulsar).getLedgerOffloaderMap();
+ doReturn(namespaceOffloader).when(pulsar)
+ .getManagedLedgerOffloader(TopicName.get(topicName).getNamespaceObject(), null);
admin.topics().removeOffloadPolicies(topicName);
Awaitility.await().atMost(10, TimeUnit.SECONDS).untilAsserted(()