[incubator-seatunnel] branch dev updated: [Improve][Connector-V2][IotDB]Add IotDB sink parameter check (#3412)

[gaojun2048]

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

gaojun2048 pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 91240a3dc [Improve][Connector-V2][IotDB]Add IotDB sink parameter check 
(#3412)
91240a3dc is described below

commit 91240a3dcbe0434e1992be61b71517f38d238cae
Author: TaoZex <45089228+tao...@users.noreply.github.com>
AuthorDate: Mon Nov 14 10:21:29 2022 +0800

    [Improve][Connector-V2][IotDB]Add IotDB sink parameter check (#3412)
---
 .../seatunnel/connectors/seatunnel/iotdb/sink/IoTDBSink.java | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git 
a/seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/sink/IoTDBSink.java
 
b/seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/sink/IoTDBSink.java
index 6ba43079b..fe00e2d81 100644
--- 
a/seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/sink/IoTDBSink.java
+++ 
b/seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/sink/IoTDBSink.java
@@ -17,12 +17,20 @@
 
 package org.apache.seatunnel.connectors.seatunnel.iotdb.sink;
 
+import static 
org.apache.seatunnel.connectors.seatunnel.iotdb.config.SinkConfig.KEY_DEVICE;
+import static 
org.apache.seatunnel.connectors.seatunnel.iotdb.config.SinkConfig.NODE_URLS;
+import static 
org.apache.seatunnel.connectors.seatunnel.iotdb.config.SinkConfig.PASSWORD;
+import static 
org.apache.seatunnel.connectors.seatunnel.iotdb.config.SinkConfig.USERNAME;
+
 import org.apache.seatunnel.api.common.PrepareFailException;
 import org.apache.seatunnel.api.sink.SeaTunnelSink;
 import org.apache.seatunnel.api.sink.SinkWriter;
 import org.apache.seatunnel.api.table.type.SeaTunnelDataType;
 import org.apache.seatunnel.api.table.type.SeaTunnelRow;
 import org.apache.seatunnel.api.table.type.SeaTunnelRowType;
+import org.apache.seatunnel.common.config.CheckConfigUtil;
+import org.apache.seatunnel.common.config.CheckResult;
+import org.apache.seatunnel.common.constants.PluginType;
 import 
org.apache.seatunnel.connectors.seatunnel.common.sink.AbstractSimpleSink;
 import 
org.apache.seatunnel.connectors.seatunnel.common.sink.AbstractSinkWriter;
 
@@ -43,6 +51,10 @@ public class IoTDBSink extends 
AbstractSimpleSink<SeaTunnelRow, Void> {
 
     @Override
     public void prepare(Config pluginConfig) throws PrepareFailException {
+        CheckResult result = CheckConfigUtil.checkAllExists(pluginConfig, 
NODE_URLS, USERNAME, PASSWORD, KEY_DEVICE);
+        if (!result.isSuccess()) {
+            throw new PrepareFailException(getPluginName(), PluginType.SINK, 
result.getMsg());
+        }
         this.pluginConfig = pluginConfig;
     }