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

rong pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new 9f5cdcead8c Pipe: Enable synonym detection for OpcUaConnector (#15573) 
(#15576)
9f5cdcead8c is described below

commit 9f5cdcead8c4a9cb48a1297565b6c32e3e057ae8
Author: Caideyipi <[email protected]>
AuthorDate: Mon May 26 16:46:08 2025 +0800

    Pipe: Enable synonym detection for OpcUaConnector (#15573) (#15576)
---
 .../iotdb/db/pipe/connector/protocol/opcua/OpcUaConnector.java     | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcua/OpcUaConnector.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcua/OpcUaConnector.java
index 78c1d8fa75f..419cb6c43eb 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcua/OpcUaConnector.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcua/OpcUaConnector.java
@@ -99,7 +99,12 @@ public class OpcUaConnector implements PipeConnector {
             SINK_OPC_UA_MODEL_KEY,
             true,
             CONNECTOR_OPC_UA_MODEL_CLIENT_SERVER_VALUE,
-            CONNECTOR_OPC_UA_MODEL_PUB_SUB_VALUE);
+            CONNECTOR_OPC_UA_MODEL_PUB_SUB_VALUE)
+        .validateSynonymAttributes(
+            Arrays.asList(CONNECTOR_IOTDB_USER_KEY, SINK_IOTDB_USER_KEY),
+            Arrays.asList(CONNECTOR_IOTDB_USERNAME_KEY, 
SINK_IOTDB_USERNAME_KEY),
+            false);
+    ;
   }
 
   @Override

Reply via email to