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;