This is an automated email from the ASF dual-hosted git repository.
jt2594838 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 5ce95b1e05c Pipe: Remove Ratis data region source restriction (#18089)
5ce95b1e05c is described below
commit 5ce95b1e05ca40d5c0f2fdf2ce8a6f91a7009a61
Author: Caideyipi <[email protected]>
AuthorDate: Fri Jul 3 09:37:47 2026 +0800
Pipe: Remove Ratis data region source restriction (#18089)
---
.../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(
