From da9b0dc27c17a84b48661343d410d57cfaae0cd6 Mon Sep 17 00:00:00 2001 From: Zhenyu Luo Date: Sat, 30 Nov 2024 03:24:35 +0800 Subject: [PATCH] Pipe IT: Modify the forwarding-pipe-requests configuration of Double Living IT (#14240) (#14260) --- .../iotdb/pipe/it/autocreate/IoTDBPipeLifeCycleIT.java | 6 ++++-- 1 file changed, 4 insertions(+), 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 index 87e00151db15..02abcde0a12d 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 void testDoubleLiving() throws Exception { final Map 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 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);