File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
pulsar-broker/src/test/java/org/apache/pulsar/broker/service Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -179,10 +179,11 @@ public void testShutDownWithMaxConcurrentUnload() throws Exception {
179
179
assertEquals (bundlesData .getNumBundles (), bundleNum );
180
180
List <String > list = admin .brokers ().getActiveBrokers ("test" );
181
181
assertEquals (list .size (), 1 );
182
+ BrokerService brokerService = pulsar .getBrokerService ();
182
183
admin .brokers ().shutDownBrokerGracefully (1 , false );
183
184
//We can only unload one bundle per second, so it takes at least 2 seconds.
184
185
Awaitility .await ().atLeast (bundleNum - 1 , TimeUnit .SECONDS ).untilAsserted (() -> {
185
- assertEquals (pulsar . getBrokerService () .getTopics ().size (), 0 );
186
+ assertEquals (brokerService .getTopics ().size (), 0 );
186
187
});
187
188
Awaitility .await ().atMost (60 , TimeUnit .SECONDS ).untilAsserted (() -> {
188
189
assertNull (pulsar .getBrokerService ());
You can’t perform that action at this time.
0 commit comments