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 2021/07/22 12:28:19 UTC
[pulsar] branch fix-11349 created (now d7caad6)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch fix-11349
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
at d7caad6 Increase zooKeeperOperationTimeoutSeconds to 10 seconds
This branch includes the following new commits:
new 42d851e Fix cleanup method (annotation cannot be removed)
new d7caad6 Increase zooKeeperOperationTimeoutSeconds to 10 seconds
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.
[pulsar] 02/02: Increase zooKeeperOperationTimeoutSeconds to 10
seconds
Posted by lh...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch fix-11349
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit d7caad6efa8f7fb067f9b5cbf6853eebc7064bf0
Author: Lari Hotari <lh...@apache.org>
AuthorDate: Thu Jul 22 15:24:33 2021 +0300
Increase zooKeeperOperationTimeoutSeconds to 10 seconds
---
.../test/java/org/apache/pulsar/broker/service/BkEnsemblesTestBase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BkEnsemblesTestBase.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BkEnsemblesTestBase.java
index 3f471f9..c67e91b 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BkEnsemblesTestBase.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BkEnsemblesTestBase.java
@@ -87,7 +87,7 @@ public abstract class BkEnsemblesTestBase extends TestRetrySupport {
config.setManagedLedgerMinLedgerRolloverTimeMinutes(0);
config.setAdvertisedAddress("127.0.0.1");
config.setAllowAutoTopicCreationType("non-partitioned");
- config.setZooKeeperOperationTimeoutSeconds(1);
+ config.setZooKeeperOperationTimeoutSeconds(10);
config.setNumIOThreads(1);
Properties properties = new Properties();
properties.put("bookkeeper_numWorkerThreads", "1");
[pulsar] 01/02: Fix cleanup method (annotation cannot be removed)
Posted by lh...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch fix-11349
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 42d851e60d3b679c62b6d16035f0a2a24ba64759
Author: Lari Hotari <lh...@apache.org>
AuthorDate: Thu Jul 22 15:22:22 2021 +0300
Fix cleanup method (annotation cannot be removed)
---
.../test/java/org/apache/pulsar/broker/service/RackAwareTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/RackAwareTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/RackAwareTest.java
index a2680a5..8e7c66e 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/RackAwareTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/RackAwareTest.java
@@ -19,7 +19,7 @@
package org.apache.pulsar.broker.service;
import static org.testng.Assert.assertTrue;
-
+import com.google.gson.Gson;
import java.io.File;
import java.nio.file.Files;
import java.util.ArrayList;
@@ -28,8 +28,6 @@ import java.util.Map;
import java.util.Set;
import java.util.TreeMap;
import java.util.stream.Collectors;
-
-import com.google.gson.Gson;
import org.apache.bookkeeper.client.BookKeeper;
import org.apache.bookkeeper.client.BookKeeper.DigestType;
import org.apache.bookkeeper.client.LedgerHandle;
@@ -44,6 +42,7 @@ import org.assertj.core.util.Lists;
import org.awaitility.Awaitility;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import org.testng.annotations.AfterMethod;
import org.testng.annotations.Test;
@Test(groups = "broker")
@@ -85,6 +84,7 @@ public class RackAwareTest extends BkEnsemblesTestBase {
}
@Override
+ @AfterMethod(alwaysRun = true)
protected void cleanup() throws Exception {
super.cleanup();