This is an automated email from the ASF dual-hosted git repository.
sijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 757d971 Add diskUsageThreshold to 0.99 (#5970)
757d971 is described below
commit 757d971b647ccc8b57051aebc8f72323919af7f1
Author: Guangning <[email protected]>
AuthorDate: Wed Jan 1 08:26:03 2020 +0800
Add diskUsageThreshold to 0.99 (#5970)
### Motivation
The current GitHub action test will show that the disk space exceeds 95%,
and then the bookie will detect that bookie exits, so fix this problem.

### Modifications
* Configuration parameter disUsageThreshold is 0.99 to prevent bookie exit.
### Verifying this change
Integration test pass
---
.../src/test/java/org/apache/pulsar/tests/integration/SmokeTest.java | 3 +++
.../src/test/java/org/apache/pulsar/tests/integration/SmokeTest.java | 3 +++
.../org/apache/pulsar/tests/integration/topologies/PulsarCluster.java | 1 +
3 files changed, 7 insertions(+)
diff --git
a/tests/bc_2_0_0/src/test/java/org/apache/pulsar/tests/integration/SmokeTest.java
b/tests/bc_2_0_0/src/test/java/org/apache/pulsar/tests/integration/SmokeTest.java
index 2b600fe..a2ca4e2 100644
---
a/tests/bc_2_0_0/src/test/java/org/apache/pulsar/tests/integration/SmokeTest.java
+++
b/tests/bc_2_0_0/src/test/java/org/apache/pulsar/tests/integration/SmokeTest.java
@@ -18,6 +18,7 @@
*/
package org.apache.pulsar.tests.integration;
+import lombok.Cleanup;
import org.apache.pulsar.client.api.Consumer;
import org.apache.pulsar.client.api.Message;
import org.apache.pulsar.client.api.Producer;
@@ -44,6 +45,8 @@ public class SmokeTest {
@Test
public void checkMessages() throws PulsarClientException {
+
+ @Cleanup
PulsarClient client = PulsarClient.builder()
.serviceUrl(pulsarContainer.getPlainTextPulsarBrokerUrl())
.build();
diff --git
a/tests/bc_2_0_1/src/test/java/org/apache/pulsar/tests/integration/SmokeTest.java
b/tests/bc_2_0_1/src/test/java/org/apache/pulsar/tests/integration/SmokeTest.java
index 2b600fe..a2ca4e2 100644
---
a/tests/bc_2_0_1/src/test/java/org/apache/pulsar/tests/integration/SmokeTest.java
+++
b/tests/bc_2_0_1/src/test/java/org/apache/pulsar/tests/integration/SmokeTest.java
@@ -18,6 +18,7 @@
*/
package org.apache.pulsar.tests.integration;
+import lombok.Cleanup;
import org.apache.pulsar.client.api.Consumer;
import org.apache.pulsar.client.api.Message;
import org.apache.pulsar.client.api.Producer;
@@ -44,6 +45,8 @@ public class SmokeTest {
@Test
public void checkMessages() throws PulsarClientException {
+
+ @Cleanup
PulsarClient client = PulsarClient.builder()
.serviceUrl(pulsarContainer.getPlainTextPulsarBrokerUrl())
.build();
diff --git
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/topologies/PulsarCluster.java
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/topologies/PulsarCluster.java
index dc7ad8a..6ffd38a 100644
---
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/topologies/PulsarCluster.java
+++
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/topologies/PulsarCluster.java
@@ -144,6 +144,7 @@ public class PulsarCluster {
.withEnv("journalSyncData", "false")
.withEnv("journalMaxGroupWaitMSec", "0")
.withEnv("clusterName", clusterName)
+ .withEnv("diskUsageThreshold", "0.99")
)
);