From ac4a057fdccb2151a82453a13f1b2a3af69d1747 Mon Sep 17 00:00:00 2001 From: Lari Hotari Date: Tue, 5 May 2026 19:36:18 +0300 Subject: [PATCH] [improve][test] Set diskUsageThreshold to 0.999 for tests to effectively disable the check --- .../pulsar/broker/service/SharedMultiBrokerPulsarCluster.java | 2 ++ .../org/apache/pulsar/broker/service/SharedPulsarCluster.java | 2 ++ 2 files changed, 4 insertions(+) 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)