diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SharedMultiBrokerPulsarCluster.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SharedMultiBrokerPulsarCluster.java index fde85c06ddb79..881bccd3d23f7 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SharedMultiBrokerPulsarCluster.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SharedMultiBrokerPulsarCluster.java @@ -162,6 +162,8 @@ private void start() throws Exception { bkConf.setNumLongPollWorkerThreads(1); bkConf.setAllocatorPoolingPolicy(PoolingPolicy.UnpooledHeap); bkConf.setLedgerStorageClass("org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage"); + bkConf.setDiskUsageThreshold(0.999F); + bkConf.setDiskUsageWarnThreshold(0.99F); bkCluster = BKCluster.builder() .baseServerConfiguration(bkConf) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SharedPulsarCluster.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SharedPulsarCluster.java index dc14b163e4dce..9b0ba169cf850 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SharedPulsarCluster.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SharedPulsarCluster.java @@ -116,6 +116,8 @@ private void start() throws Exception { bkConf.setNumLongPollWorkerThreads(1); bkConf.setAllocatorPoolingPolicy(PoolingPolicy.UnpooledHeap); bkConf.setLedgerStorageClass("org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage"); + bkConf.setDiskUsageThreshold(0.999F); + bkConf.setDiskUsageWarnThreshold(0.99F); bkCluster = BKCluster.builder() .baseServerConfiguration(bkConf)