[iotdb] 02/05: iotdb-thrift-connector -> iotdb-thrift-async-connector

[rong]

This is an automated email from the ASF dual-hosted git repository.

rong pushed a commit to branch fix-pipe-cause-wal-pin
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit cd3c3b0a546941703d5a4a78baf2605879800508
Author: Steve Yurong Su <r...@apache.org>
AuthorDate: Thu Sep 28 12:26:33 2023 +0800

    iotdb-thrift-connector -> iotdb-thrift-async-connector
---
 .../db/pipe/task/subtask/connector/PipeConnectorSubtaskManager.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/connector/PipeConnectorSubtaskManager.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/connector/PipeConnectorSubtaskManager.java
index 455d113f4d7..fbff28fed45 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/connector/PipeConnectorSubtaskManager.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/connector/PipeConnectorSubtaskManager.java
@@ -180,7 +180,7 @@ public class PipeConnectorSubtaskManager {
   private PipeConnectorSubtaskManager() {
     CONNECTOR_CONSTRUCTORS.put(
         BuiltinPipePlugin.IOTDB_THRIFT_CONNECTOR.getPipePluginName(),
-        IoTDBThriftSyncConnector::new);
+        IoTDBThriftAsyncConnector::new);
     CONNECTOR_CONSTRUCTORS.put(
         BuiltinPipePlugin.IOTDB_THRIFT_SYNC_CONNECTOR.getPipePluginName(),
         IoTDBThriftSyncConnector::new);