This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch pipe-sep
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/pipe-sep by this push:
new bc0ff21861c snapshot
bc0ff21861c is described below
commit bc0ff21861c6c84ce28ebffea0da09c0b7c62ef3
Author: Caideyipi <[email protected]>
AuthorDate: Fri Mar 13 16:06:23 2026 +0800
snapshot
---
.../plan/execution/config/executor/ClusterConfigTaskExecutor.java | 2 ++
1 file changed, 2 insertions(+)
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 d28edddb2f9..219c060892b 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
@@ -2253,6 +2253,8 @@ public class ClusterConfigTaskExecutor implements
IConfigTaskExecutor {
Boolean.toString(false),
PipeSourceConstant.EXTRACTOR_HISTORY_ENABLE_KEY,
Boolean.toString(true),
+ PipeSourceConstant.EXTRACTOR_MODE_KEY,
+
PipeSourceConstant.EXTRACTOR_MODE_SNAPSHOT_VALUE,
// We force the historical pipe to
transfer data only
// Thus we can transfer schema only once
// And may drop the historical pipe on
successfully transferred
