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));

Reply via email to