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