This is an automated email from the ASF dual-hosted git repository. Caideyipi pushed a commit to branch fix/remove-pipe-ratis-consensus-restriction in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 30d90960b4def2a498fce83fcbd6841f859c7f27 Author: Caideyipi <[email protected]> AuthorDate: Thu Jul 2 10:51:06 2026 +0800 Pipe: Remove Ratis data region source restriction --- .../i18n/en/org/apache/iotdb/db/i18n/DataNodePipeMessages.java | 2 -- .../i18n/zh/org/apache/iotdb/db/i18n/DataNodePipeMessages.java | 2 -- .../iotdb/db/pipe/source/dataregion/IoTDBDataRegionSource.java | 10 ---------- 3 files changed, 14 deletions(-) diff --git a/iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodePipeMessages.java b/iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodePipeMessages.java index bfac58fbab1..00efec4d3a8 100644 --- a/iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodePipeMessages.java +++ b/iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodePipeMessages.java @@ -611,8 +611,6 @@ public final class DataNodePipeMessages { "The pipe cannot extract table model data when sql dialect is set to tree."; public static final String THE_PIPE_CANNOT_EXTRACT_TREE_MODEL_DATA = "The pipe cannot extract tree model data when sql dialect is set to table."; - public static final String THE_PIPE_CANNOT_TRANSFER_DATA_WHEN_DATA = - "The pipe cannot transfer data when data region is using ratis consensus."; public static final String THE_REFERENCE_COUNT_OF_THE_EVENT_CANNOT = "The reference count of the event {} cannot be increased, skipping it."; public static final String THE_REFERENCE_COUNT_OF_THE_REALTIME_EVENT = diff --git a/iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/DataNodePipeMessages.java b/iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/DataNodePipeMessages.java index 6fbc50ac13b..3c53b1909bb 100644 --- a/iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/DataNodePipeMessages.java +++ b/iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/DataNodePipeMessages.java @@ -584,8 +584,6 @@ public final class DataNodePipeMessages { "The pipe cannot extract table model data when sql dialect is set to tree."; public static final String THE_PIPE_CANNOT_EXTRACT_TREE_MODEL_DATA = "The pipe cannot extract tree model data when sql dialect is set to table."; - public static final String THE_PIPE_CANNOT_TRANSFER_DATA_WHEN_DATA = - "The pipe cannot transfer data when data region is using ratis consensus."; public static final String THE_REFERENCE_COUNT_OF_THE_EVENT_CANNOT = "The reference count of the event {} cannot be increased, skipping it."; public static final String THE_REFERENCE_COUNT_OF_THE_REALTIME_EVENT = diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/IoTDBDataRegionSource.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/IoTDBDataRegionSource.java index c5dc7662bbc..1b1f5a7df7c 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/IoTDBDataRegionSource.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/IoTDBDataRegionSource.java @@ -27,8 +27,6 @@ import org.apache.iotdb.commons.pipe.datastructure.pattern.IoTDBTreePatternOpera import org.apache.iotdb.commons.pipe.datastructure.pattern.TreePattern; import org.apache.iotdb.commons.pipe.source.IoTDBSource; import org.apache.iotdb.commons.queryengine.common.SqlDialect; -import org.apache.iotdb.consensus.ConsensusFactory; -import org.apache.iotdb.db.conf.IoTDBDescriptor; import org.apache.iotdb.db.i18n.DataNodePipeMessages; import org.apache.iotdb.db.pipe.event.common.heartbeat.PipeHeartbeatEvent; import org.apache.iotdb.db.pipe.metric.overview.PipeDataNodeSinglePipeMetrics; @@ -152,14 +150,6 @@ public class IoTDBDataRegionSource extends IoTDBSource { hasNoExtractionNeed = false; shouldExtractDeletion = insertionDeletionListeningOptionPair.getRight(); - if (insertionDeletionListeningOptionPair.getLeft().equals(true) - && IoTDBDescriptor.getInstance() - .getConfig() - .getDataRegionConsensusProtocolClass() - .equals(ConsensusFactory.RATIS_CONSENSUS)) { - throw new PipeException(DataNodePipeMessages.THE_PIPE_CANNOT_TRANSFER_DATA_WHEN_DATA); - } - // Validate source.pattern.format is within valid range validator .validateAttributeValueRange(
