This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch opc-ua
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/opc-ua by this push:
new eb88544cb3c bug-fix
eb88544cb3c is described below
commit eb88544cb3cba64c9d347f483a5e022d1c147cb6
Author: Caideyipi <[email protected]>
AuthorDate: Wed Dec 17 16:07:02 2025 +0800
bug-fix
---
.../org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaSink.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaSink.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaSink.java
index e698130c107..7404a8b03bc 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaSink.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaSink.java
@@ -66,11 +66,13 @@ import static
org.apache.iotdb.commons.pipe.config.constant.PipeSinkConstant.CON
import static
org.apache.iotdb.commons.pipe.config.constant.PipeSinkConstant.CONNECTOR_OPC_UA_MODEL_PUB_SUB_VALUE;
import static
org.apache.iotdb.commons.pipe.config.constant.PipeSinkConstant.CONNECTOR_OPC_UA_PLACEHOLDER_DEFAULT_VALUE;
import static
org.apache.iotdb.commons.pipe.config.constant.PipeSinkConstant.CONNECTOR_OPC_UA_PLACEHOLDER_KEY;
+import static
org.apache.iotdb.commons.pipe.config.constant.PipeSinkConstant.CONNECTOR_OPC_UA_QUALITY_NAME_DEFAULT_VALUE;
import static
org.apache.iotdb.commons.pipe.config.constant.PipeSinkConstant.CONNECTOR_OPC_UA_QUALITY_NAME_KEY;
import static
org.apache.iotdb.commons.pipe.config.constant.PipeSinkConstant.CONNECTOR_OPC_UA_SECURITY_DIR_DEFAULT_VALUE;
import static
org.apache.iotdb.commons.pipe.config.constant.PipeSinkConstant.CONNECTOR_OPC_UA_SECURITY_DIR_KEY;
import static
org.apache.iotdb.commons.pipe.config.constant.PipeSinkConstant.CONNECTOR_OPC_UA_TCP_BIND_PORT_DEFAULT_VALUE;
import static
org.apache.iotdb.commons.pipe.config.constant.PipeSinkConstant.CONNECTOR_OPC_UA_TCP_BIND_PORT_KEY;
+import static
org.apache.iotdb.commons.pipe.config.constant.PipeSinkConstant.CONNECTOR_OPC_UA_VALUE_NAME_DEFAULT_VALUE;
import static
org.apache.iotdb.commons.pipe.config.constant.PipeSinkConstant.CONNECTOR_OPC_UA_VALUE_NAME_KEY;
import static
org.apache.iotdb.commons.pipe.config.constant.PipeSinkConstant.CONNECTOR_OPC_UA_WITH_QUALITY_DEFAULT_VALUE;
import static
org.apache.iotdb.commons.pipe.config.constant.PipeSinkConstant.CONNECTOR_OPC_UA_WITH_QUALITY_KEY;
@@ -183,13 +185,13 @@ public class OpcUaSink implements PipeConnector {
withQuality
? parameters.getStringOrDefault(
Arrays.asList(CONNECTOR_OPC_UA_VALUE_NAME_KEY,
SINK_OPC_UA_VALUE_NAME_KEY),
- CONNECTOR_OPC_UA_MODEL_DEFAULT_VALUE)
+ CONNECTOR_OPC_UA_VALUE_NAME_DEFAULT_VALUE)
: null;
qualityName =
withQuality
? parameters.getStringOrDefault(
Arrays.asList(CONNECTOR_OPC_UA_QUALITY_NAME_KEY,
SINK_OPC_UA_QUALITY_NAME_KEY),
- CONNECTOR_OPC_UA_MODEL_DEFAULT_VALUE)
+ CONNECTOR_OPC_UA_QUALITY_NAME_DEFAULT_VALUE)
: null;
isClientServerModel =
parameters
