This is an automated email from the ASF dual-hosted git repository.
jt2594838 pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/dev/1.3 by this push:
new 23e40d4b97c Pipe: Remove Ratis data region source restriction (#18089)
(#18100)
23e40d4b97c is described below
commit 23e40d4b97cd898a618408d40b7e281516727b73
Author: Caideyipi <[email protected]>
AuthorDate: Mon Jul 6 10:54:28 2026 +0800
Pipe: Remove Ratis data region source restriction (#18089) (#18100)
(cherry picked from commit 5ce95b1e05ca40d5c0f2fdf2ce8a6f91a7009a61)
---
.../db/pipe/source/dataregion/IoTDBDataRegionSource.java | 11 -----------
1 file changed, 11 deletions(-)
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 77195ab58df..6df5e10d0a2 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
@@ -24,8 +24,6 @@ import org.apache.iotdb.commons.pipe.agent.task.PipeTaskAgent;
import
org.apache.iotdb.commons.pipe.datastructure.pattern.IoTDBPipePatternOperations;
import org.apache.iotdb.commons.pipe.datastructure.pattern.PipePattern;
import org.apache.iotdb.commons.pipe.source.IoTDBSource;
-import org.apache.iotdb.consensus.ConsensusFactory;
-import org.apache.iotdb.db.conf.IoTDBDescriptor;
import org.apache.iotdb.db.pipe.event.common.heartbeat.PipeHeartbeatEvent;
import org.apache.iotdb.db.pipe.metric.overview.PipeDataNodeSinglePipeMetrics;
import org.apache.iotdb.db.pipe.metric.overview.PipeTsFileToTabletsMetrics;
@@ -110,15 +108,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(
- "The pipe cannot transfer data when data region is using ratis
consensus.");
- }
-
// Validate source.pattern.format is within valid range
validator
.validateAttributeValueRange(
