You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2024/11/29 02:38:26 UTC
(iotdb) branch master updated: Pipe IT: Modify the forwarding-pipe-requests configuration of Double Living IT (#14240)
This is an automated email from the ASF dual-hosted git repository.
rong 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 6eb576cc9fb Pipe IT: Modify the forwarding-pipe-requests configuration of Double Living IT (#14240)
6eb576cc9fb is described below
commit 6eb576cc9fb76e6e09809da07c59d9eb5b7d77a4
Author: Zhenyu Luo <lu...@gmail.com>
AuthorDate: Fri Nov 29 10:38:20 2024 +0800
Pipe IT: Modify the forwarding-pipe-requests configuration of Double Living IT (#14240)
---
.../org/apache/iotdb/pipe/it/autocreate/IoTDBPipeLifeCycleIT.java | 6 ++++--
.../org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeLifeCycleIT.java | 6 ++++--
2 files changed, 8 insertions(+), 4 deletions(-)
diff --git a/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeLifeCycleIT.java b/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeLifeCycleIT.java
index e4ae21e8543..d1ee92fd141 100644
--- a/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeLifeCycleIT.java
+++ b/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeLifeCycleIT.java
@@ -648,7 +648,8 @@ public class IoTDBPipeLifeCycleIT extends AbstractPipeDualAutoIT {
final Map<String, String> connectorAttributes = new HashMap<>();
// Add this property to avoid to make self cycle.
- connectorAttributes.put("source.forwarding-pipe-requests", "false");
+ extractorAttributes.put("source.forwarding-pipe-requests", "false");
+
connectorAttributes.put("connector", "iotdb-thrift-connector");
connectorAttributes.put("connector.batch.enable", "false");
connectorAttributes.put("connector.ip", receiverIp);
@@ -691,7 +692,8 @@ public class IoTDBPipeLifeCycleIT extends AbstractPipeDualAutoIT {
final Map<String, String> connectorAttributes = new HashMap<>();
// Add this property to avoid to make self cycle.
- connectorAttributes.put("source.forwarding-pipe-requests", "false");
+ extractorAttributes.put("source.forwarding-pipe-requests", "false");
+
connectorAttributes.put("connector", "iotdb-thrift-connector");
connectorAttributes.put("connector.batch.enable", "false");
connectorAttributes.put("connector.ip", senderIp);
diff --git a/integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeLifeCycleIT.java b/integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeLifeCycleIT.java
index 3e2520fde99..89bba66a651 100644
--- a/integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeLifeCycleIT.java
+++ b/integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeLifeCycleIT.java
@@ -561,7 +561,8 @@ public class IoTDBPipeLifeCycleIT extends AbstractPipeTableModelTestIT {
// Add this property to avoid to make self cycle.
extractorAttributes.put("capture.table", "true");
- connectorAttributes.put("source.forwarding-pipe-requests", "false");
+ extractorAttributes.put("forwarding-pipe-requests", "false");
+
connectorAttributes.put("connector", "iotdb-thrift-connector");
connectorAttributes.put("connector.batch.enable", "false");
connectorAttributes.put("connector.ip", receiverIp);
@@ -600,7 +601,8 @@ public class IoTDBPipeLifeCycleIT extends AbstractPipeTableModelTestIT {
// Add this property to avoid to make self cycle.
extractorAttributes.put("capture.table", "true");
extractorAttributes.put("capture.tree", "true");
- connectorAttributes.put("source.forwarding-pipe-requests", "false");
+ extractorAttributes.put("forwarding-pipe-requests", "false");
+
connectorAttributes.put("connector", "iotdb-thrift-connector");
connectorAttributes.put("connector.batch.enable", "false");
connectorAttributes.put("connector.ip", senderIp);