This is an automated email from the ASF dual-hosted git repository. justinchen pushed a commit to branch chainge-13 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit addd812d6c24ac62af68da371c761621c0392344 Author: Caideyipi <[email protected]> AuthorDate: Thu Mar 5 17:38:01 2026 +0800 Avoid someone merge with name 'may-comp' --- .../iotdb/db/pipe/agent/task/builder/PipeDataNodeTaskBuilder.java | 3 ++- .../plan/execution/config/executor/ClusterConfigTaskExecutor.java | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/builder/PipeDataNodeTaskBuilder.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/builder/PipeDataNodeTaskBuilder.java index e767731c1ac..8d227d7c272 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/builder/PipeDataNodeTaskBuilder.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/builder/PipeDataNodeTaskBuilder.java @@ -210,7 +210,8 @@ public class PipeDataNodeTaskBuilder { PipeSinkConstant.CONNECTOR_ENABLE_SEND_TSFILE_LIMIT); if (enableSendTsFileLimit == null) { - sinkParameters.addAttribute(PipeSinkConstant.SINK_ENABLE_SEND_TSFILE_LIMIT, "true"); + sinkParameters.addAttribute( + PipeSinkConstant.SINK_ENABLE_SEND_TSFILE_LIMIT, Boolean.TRUE.toString()); LOGGER.info( "PipeDataNodeTaskBuilder: When the realtime sync is enabled, we enable rate limiter in sending tsfile by default to reserve disk and network IO for realtime sending."); } else if (!enableSendTsFileLimit) { diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java index 1b287840055..24c64c24030 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java @@ -1896,7 +1896,8 @@ public class ClusterConfigTaskExecutor implements IConfigTaskExecutor { .addOrReplaceEquivalentAttributesWithClone( new PipeParameters( Collections.singletonMap( - PipeSinkConstant.SINK_ENABLE_SEND_TSFILE_LIMIT, "true"))) + PipeSinkConstant.SINK_ENABLE_SEND_TSFILE_LIMIT, + Boolean.TRUE.toString()))) .getAttribute()); final TSStatus historyTsStatus = configNodeClient.createPipe(historyReq);
