This is an automated email from the ASF dual-hosted git repository. justinchen pushed a commit to branch md in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 48b164d59ef216159ff7e868e31d5a30aba810f9 Author: Caideyipi <[email protected]> AuthorDate: Mon Jan 19 19:03:10 2026 +0800 bz --- .../org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java | 6 ++++-- .../historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java | 3 ++- .../apache/iotdb/commons/pipe/config/constant/SystemConstant.java | 2 +- 3 files changed, 7 insertions(+), 4 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java index 438dfa3f233..44f02bbd4bb 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java @@ -778,7 +778,8 @@ public class PipeDataNodeTaskAgent extends PipeTaskAgent { // If the source is not history, we do not need to allocate memory boolean isExtractorHistory = sourceParameters.getBooleanOrDefault( - SystemConstant.RESTART_OR_NEWLY_ADDED_KEY, SystemConstant.RESTART_DEFAULT_VALUE) + SystemConstant.RESTART_OR_NEWLY_ADDED_KEY, + SystemConstant.RESTART_OR_NEWLY_ADDED_DEFAULT_VALUE) || sourceParameters.getBooleanOrDefault( Arrays.asList(EXTRACTOR_HISTORY_ENABLE_KEY, SOURCE_HISTORY_ENABLE_KEY), EXTRACTOR_HISTORY_ENABLE_DEFAULT_VALUE); @@ -862,7 +863,8 @@ public class PipeDataNodeTaskAgent extends PipeTaskAgent { // If the source is history enable, we need to transfer tsfile boolean needTransferTsFile = sourceParameters.getBooleanOrDefault( - SystemConstant.RESTART_OR_NEWLY_ADDED_KEY, SystemConstant.RESTART_DEFAULT_VALUE) + SystemConstant.RESTART_OR_NEWLY_ADDED_KEY, + SystemConstant.RESTART_OR_NEWLY_ADDED_DEFAULT_VALUE) || sourceParameters.getBooleanOrDefault( Arrays.asList(EXTRACTOR_HISTORY_ENABLE_KEY, SOURCE_HISTORY_ENABLE_KEY), EXTRACTOR_HISTORY_ENABLE_DEFAULT_VALUE); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java index 3112c3220fe..7d3eb722f8c 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java @@ -256,7 +256,8 @@ public class PipeHistoricalDataRegionTsFileAndDeletionSource // enabling the historical data extraction, which may affect the realtime data extraction. isHistoricalSourceEnabled = parameters.getBooleanOrDefault( - SystemConstant.RESTART_OR_NEWLY_ADDED_KEY, SystemConstant.RESTART_DEFAULT_VALUE) + SystemConstant.RESTART_OR_NEWLY_ADDED_KEY, + SystemConstant.RESTART_OR_NEWLY_ADDED_DEFAULT_VALUE) || parameters.getBooleanOrDefault( Arrays.asList(EXTRACTOR_HISTORY_ENABLE_KEY, SOURCE_HISTORY_ENABLE_KEY), EXTRACTOR_HISTORY_ENABLE_DEFAULT_VALUE); diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/SystemConstant.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/SystemConstant.java index de0d6050167..30475bf9688 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/SystemConstant.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/SystemConstant.java @@ -36,7 +36,7 @@ public class SystemConstant { // This can be arbitrarily changed since it's only a memory key and not stored public static final String RESTART_OR_NEWLY_ADDED_KEY = "__system.restart_or_newly_added"; - public static final boolean RESTART_DEFAULT_VALUE = false; + public static final boolean RESTART_OR_NEWLY_ADDED_DEFAULT_VALUE = false; public static final String SQL_DIALECT_KEY = "__system.sql-dialect"; public static final String SQL_DIALECT_TREE_VALUE = "tree";
