This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.1 by this push:
new 8b24a577a66 branch-4.1: [fix](load) reduce S3 upload queue
backpressure threshold #67058 (#67077)
8b24a577a66 is described below
commit 8b24a577a66ac12afcc123334e2710a9cd4cb8d0
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Aug 25 09:51:05 2026 +0800
branch-4.1: [fix](load) reduce S3 upload queue backpressure threshold
#67058 (#67077)
Cherry-picked from #67058
Co-authored-by: hui lai <[email protected]>
---
be/src/storage/adaptive_thread_pool_controller.h | 2 +-
be/test/storage/adaptive_thread_pool_controller_test.cpp | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/be/src/storage/adaptive_thread_pool_controller.h
b/be/src/storage/adaptive_thread_pool_controller.h
index 0598531268c..ae78b7883dd 100644
--- a/be/src/storage/adaptive_thread_pool_controller.h
+++ b/be/src/storage/adaptive_thread_pool_controller.h
@@ -80,7 +80,7 @@ public:
static constexpr int kQueueThreshold = 10;
static constexpr int kIOBusyThresholdPercent = 90;
static constexpr int kCPUBusyThresholdPercent = 90;
- static constexpr int kS3QueueBusyThreshold = 100;
+ static constexpr int kS3QueueBusyThreshold = 10;
AdaptiveThreadPoolController() = default;
~AdaptiveThreadPoolController() { stop(); }
diff --git a/be/test/storage/adaptive_thread_pool_controller_test.cpp
b/be/test/storage/adaptive_thread_pool_controller_test.cpp
index 6c4e42fea05..8e3b34841f8 100644
--- a/be/test/storage/adaptive_thread_pool_controller_test.cpp
+++ b/be/test/storage/adaptive_thread_pool_controller_test.cpp
@@ -226,7 +226,7 @@ TEST_F(AdaptiveThreadPoolControllerTest, TestConstants) {
EXPECT_EQ(AdaptiveThreadPoolController::kQueueThreshold, 10);
EXPECT_EQ(AdaptiveThreadPoolController::kIOBusyThresholdPercent, 90);
EXPECT_EQ(AdaptiveThreadPoolController::kCPUBusyThresholdPercent, 90);
- EXPECT_EQ(AdaptiveThreadPoolController::kS3QueueBusyThreshold, 100);
+ EXPECT_EQ(AdaptiveThreadPoolController::kS3QueueBusyThreshold, 10);
}
// Test add after controller is already running
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
