Pipe IT: Modify the forwarding-pipe-requests configuration of Double Living IT (apache#14240)

Author: luoluoyuyu

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);

integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeLifeCycleIT.java

@@ -561,7 +561,8 @@ public void testDoubleLiving() throws Exception {
 
       // 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 void testDoubleLiving() throws Exception {
       // 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);