This is an automated email from the ASF dual-hosted git repository.

justinchen pushed a commit to branch wait_time
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/wait_time by this push:
     new 4cfbb307deb fix
4cfbb307deb is described below

commit 4cfbb307debfaed5bcb2b1a96e4ac80b21a6546d
Author: Caideyipi <[email protected]>
AuthorDate: Tue Nov 25 10:36:44 2025 +0800

    fix
---
 .../src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
index 4e748ce647c..cd0645adf4c 100644
--- 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
+++ 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
@@ -254,8 +254,8 @@ public class CommonConfig {
   private long pipeSubtaskExecutorBasicCheckPointIntervalByTimeDuration = 10 * 
1000L;
   private long pipeSubtaskExecutorPendingQueueMaxBlockingTimeMs = 50;
 
-  private long pipeSinkSubtaskSleepIntervalInitMs = 250L;
-  private long pipeSinkSubtaskSleepIntervalMaxMs = 1000L;
+  private volatile long pipeSinkSubtaskSleepIntervalInitMs = 250L;
+  private volatile long pipeSinkSubtaskSleepIntervalMaxMs = 1000L;
 
   private long pipeSubtaskExecutorCronHeartbeatEventIntervalSeconds = 20;
 

Reply via email to