This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch pipe-ssl-refactor in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit c639d2cdd71aec68425144a4174f68b4adcf66d9 Author: Steve Yurong Su <[email protected]> AuthorDate: Wed Dec 13 16:42:19 2023 +0800 Pipe: allow not specifying connector in kv attrs --- .../iotdb/db/pipe/agent/plugin/PipeConnectorConstructor.java | 8 -------- 1 file changed, 8 deletions(-) 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 6ab65c67282..5422d6fc29f 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 @@ -32,7 +32,6 @@ 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; import java.util.Arrays; @@ -95,13 +94,6 @@ public class PipeConnectorConstructor extends PipePluginConstructor { @Override PipeConnector reflectPlugin(PipeParameters connectorParameters) { - if (!connectorParameters.hasAnyAttributes( - PipeConnectorConstant.CONNECTOR_KEY, PipeConnectorConstant.SINK_KEY)) { - throw new PipeException( - "Failed to reflect PipeConnector instance because " - + "'connector' is not specified in the parameters."); - } - return (PipeConnector) reflectPluginByKey( connectorParameters
