This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch rc/1.3.0 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 108def07463222632194a80700fc44897c82c9b6 Author: HTHou <[email protected]> AuthorDate: Wed Dec 20 15:21:05 2023 +0800 fix compile --- example/pipe-opc-ua-sink/pom.xml | 2 +- .../apache/iotdb/db/pipe/agent/plugin/PipeConnectorConstructor.java | 5 ----- 2 files changed, 1 insertion(+), 6 deletions(-) diff --git a/example/pipe-opc-ua-sink/pom.xml b/example/pipe-opc-ua-sink/pom.xml index 17810560695..e9be5215060 100644 --- a/example/pipe-opc-ua-sink/pom.xml +++ b/example/pipe-opc-ua-sink/pom.xml @@ -39,4 +39,4 @@ <artifactId>sdk-server</artifactId> </dependency> </dependencies> -</project> \ No newline at end of file +</project> diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/PipeConnectorConstructor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/PipeConnectorConstructor.java index 0137f1c3c7e..ad386bb424e 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/PipeConnectorConstructor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/PipeConnectorConstructor.java @@ -29,7 +29,6 @@ import org.apache.iotdb.db.pipe.connector.protocol.opcua.OpcUaConnector; import org.apache.iotdb.db.pipe.connector.protocol.thrift.async.IoTDBThriftAsyncConnector; import org.apache.iotdb.db.pipe.connector.protocol.thrift.sync.IoTDBThriftSyncConnector; import org.apache.iotdb.db.pipe.connector.protocol.websocket.WebSocketConnector; -import org.apache.iotdb.db.pipe.connector.protocol.writeback.WriteBackConnector; import org.apache.iotdb.pipe.api.PipeConnector; import org.apache.iotdb.pipe.api.customizer.parameter.PipeParameters; import org.apache.iotdb.pipe.api.exception.PipeException; @@ -64,8 +63,6 @@ public class PipeConnectorConstructor extends PipePluginConstructor { BuiltinPipePlugin.OPC_UA_CONNECTOR.getPipePluginName(), OpcUaConnector::new); PLUGIN_CONSTRUCTORS.put( BuiltinPipePlugin.DO_NOTHING_CONNECTOR.getPipePluginName(), DoNothingConnector::new); - PLUGIN_CONSTRUCTORS.put( - BuiltinPipePlugin.WRITE_BACK_CONNECTOR.getPipePluginName(), WriteBackConnector::new); PLUGIN_CONSTRUCTORS.put( BuiltinPipePlugin.IOTDB_THRIFT_SINK.getPipePluginName(), IoTDBThriftAsyncConnector::new); @@ -85,8 +82,6 @@ public class PipeConnectorConstructor extends PipePluginConstructor { PLUGIN_CONSTRUCTORS.put(BuiltinPipePlugin.OPC_UA_SINK.getPipePluginName(), OpcUaConnector::new); PLUGIN_CONSTRUCTORS.put( BuiltinPipePlugin.DO_NOTHING_SINK.getPipePluginName(), DoNothingConnector::new); - PLUGIN_CONSTRUCTORS.put( - BuiltinPipePlugin.WRITE_BACK_SINK.getPipePluginName(), WriteBackConnector::new); } @Override
