This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch pipe-param-modification in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 23e3d411025cb8f3efbc283de8163ff789c9eddc Author: Steve Yurong Su <[email protected]> AuthorDate: Tue May 28 18:09:12 2024 +0800 Make sink.realtime-first default value true --- .../java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeDataSinkIT.java | 4 ++-- .../iotdb/commons/pipe/config/constant/PipeConnectorConstant.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeDataSinkIT.java b/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeDataSinkIT.java index d3bfe710aca..50a9b0d2ec5 100644 --- a/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeDataSinkIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeDataSinkIT.java @@ -43,7 +43,7 @@ import java.util.Map; @Category({MultiClusterIT2AutoCreateSchema.class}) public class IoTDBPipeDataSinkIT extends AbstractPipeDualAutoIT { @Test - public void testThriftConnectorWithRealtimeFirst() throws Exception { + public void testThriftConnectorWithRealtimeFirstDisabled() throws Exception { final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0); final String receiverIp = receiverDataNode.getIp(); @@ -70,7 +70,7 @@ public class IoTDBPipeDataSinkIT extends AbstractPipeDualAutoIT { connectorAttributes.put("connector.batch.enable", "false"); connectorAttributes.put("connector.ip", receiverIp); connectorAttributes.put("connector.port", Integer.toString(receiverPort)); - connectorAttributes.put("connector.realtime-first", "true"); + connectorAttributes.put("connector.realtime-first", "false"); final TSStatus status = client.createPipe( diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/PipeConnectorConstant.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/PipeConnectorConstant.java index 5e73c4d54d8..a7da7c3ef68 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/PipeConnectorConstant.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/PipeConnectorConstant.java @@ -55,7 +55,7 @@ public class PipeConnectorConstant { public static final String CONNECTOR_REALTIME_FIRST_KEY = "connector.realtime-first"; public static final String SINK_REALTIME_FIRST_KEY = "sink.realtime-first"; - public static final boolean CONNECTOR_REALTIME_FIRST_DEFAULT_VALUE = false; + public static final boolean CONNECTOR_REALTIME_FIRST_DEFAULT_VALUE = true; public static final String CONNECTOR_IOTDB_BATCH_MODE_ENABLE_KEY = "connector.batch.enable"; public static final String SINK_IOTDB_BATCH_MODE_ENABLE_KEY = "sink.batch.enable";
