This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch new_opc_server
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/new_opc_server by this push:
new 40be65637fe polish
40be65637fe is described below
commit 40be65637fee9cf73bd75d7a8adfad661339ac01
Author: Caideyipi <[email protected]>
AuthorDate: Thu Dec 4 15:20:52 2025 +0800
polish
---
.../src/main/java/org/apache/iotdb/opcua/ClientTest.java | 3 ++-
.../org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaNameSpace.java | 2 +-
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git
a/example/pipe-opc-ua-sink/src/main/java/org/apache/iotdb/opcua/ClientTest.java
b/example/pipe-opc-ua-sink/src/main/java/org/apache/iotdb/opcua/ClientTest.java
index 560ebe609cb..f0ddea1d1e3 100644
---
a/example/pipe-opc-ua-sink/src/main/java/org/apache/iotdb/opcua/ClientTest.java
+++
b/example/pipe-opc-ua-sink/src/main/java/org/apache/iotdb/opcua/ClientTest.java
@@ -26,6 +26,7 @@ import org.eclipse.milo.opcua.sdk.core.ValueRanks;
import org.eclipse.milo.opcua.stack.core.Identifiers;
import org.eclipse.milo.opcua.stack.core.types.builtin.ByteString;
import org.eclipse.milo.opcua.stack.core.types.builtin.DataValue;
+import org.eclipse.milo.opcua.stack.core.types.builtin.DateTime;
import org.eclipse.milo.opcua.stack.core.types.builtin.ExtensionObject;
import org.eclipse.milo.opcua.stack.core.types.builtin.LocalizedText;
import org.eclipse.milo.opcua.stack.core.types.builtin.NodeId;
@@ -67,7 +68,7 @@ public class ClientTest implements ClientExample {
// 2. 尝试写入新值
Variant newValue = new Variant(42.0);
- DataValue writeValue = new DataValue(newValue, null, null);
+ DataValue writeValue = new DataValue(newValue, StatusCode.GOOD, new
DateTime(), new DateTime());
System.out.println("尝试写入值: " + newValue.getValue());
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaNameSpace.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaNameSpace.java
index 160a2e96e36..79571b18e29 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaNameSpace.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaNameSpace.java
@@ -537,7 +537,7 @@ public class OpcUaNameSpace extends
ManagedNamespaceWithLifecycle {
getNodeManager().addNode(measurementNode);
parentNode.addReference(
new Reference(
- measurementNode.getNodeId(),
+ parentNode.getNodeId(),
item.getReferenceTypeId(),
measurementNode.getNodeId().expanded(),
true));