Pipe IT: Modify the forwarding-pipe-requests configuration of Double …

…Living IT (#14240) (#14260)
apache · Nov 29, 2024 · da9b0dc · da9b0dc
1 parent deec0fb
commit da9b0dc
Showing 1 changed file with 4 additions and 2 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
@@ -648,7 +648,8 @@ public void testDoubleLiving() throws Exception {
       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 void testDoubleLiving() throws Exception {
       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);