(iotdb) branch master updated: Pipe IT: Avoid infinite self-loop request forwarding in IoTDBPipeLifeCycleIT.testDoubleLiving (#11746)

[rong]

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 64599d9db38 Pipe IT: Avoid infinite self-loop request forwarding in 
IoTDBPipeLifeCycleIT.testDoubleLiving (#11746)
64599d9db38 is described below

commit 64599d9db38e3a00d12d01b44278d11a0b4516ec
Author: Xuan Ronaldo <xuanrona...@qq.com>
AuthorDate: Tue Dec 19 16:31:56 2023 +0800

    Pipe IT: Avoid infinite self-loop request forwarding in 
IoTDBPipeLifeCycleIT.testDoubleLiving (#11746)
---
 .../src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeLifeCycleIT.java  | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeLifeCycleIT.java
 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeLifeCycleIT.java
index b7eacc79c87..aadf05a9b6b 100644
--- 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeLifeCycleIT.java
+++ 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeLifeCycleIT.java
@@ -600,6 +600,8 @@ public class IoTDBPipeLifeCycleIT extends 
AbstractPipeDualIT {
       Map<String, String> processorAttributes = new HashMap<>();
       Map<String, String> connectorAttributes = new HashMap<>();
 
+      // add this property to avoid to make self cycle.
+      connectorAttributes.put("source.forwarding-pipe-requests", "false");
       connectorAttributes.put("connector", "iotdb-thrift-connector");
       connectorAttributes.put("connector.batch.enable", "false");
       connectorAttributes.put("connector.ip", receiverIp);
@@ -638,6 +640,8 @@ public class IoTDBPipeLifeCycleIT extends 
AbstractPipeDualIT {
       Map<String, String> processorAttributes = new HashMap<>();
       Map<String, String> connectorAttributes = new HashMap<>();
 
+      // add this property to avoid to make self cycle.
+      connectorAttributes.put("source.forwarding-pipe-requests", "false");
       connectorAttributes.put("connector", "iotdb-thrift-connector");
       connectorAttributes.put("connector.batch.enable", "false");
       connectorAttributes.put("connector.ip", senderIp);