Skip to content

Commit 74a917c

Browse files
committed
sit-comp
1 parent 77c9cd3 commit 74a917c

File tree

1 file changed

+2
-2
lines changed
  • iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/client

1 file changed

+2
-2
lines changed

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/client/IoTDBOpcUaClient.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -150,7 +150,7 @@ private void transferTabletRowForClientServerModel(
150150
throw new PipeException(
151151
"Failed to transfer dataValue after successfully created nodes, error: " + writeStatus);
152152
}
153-
} else {
153+
} else if (writeStatus.getValue() != StatusCode.GOOD.getValue()){
154154
throw new PipeException("Failed to transfer dataValue, error: " + writeStatus);
155155
}
156156
}
@@ -233,7 +233,7 @@ public static VariableAttributes createMeasurementAttributes(
233233
LocalizedText.english(name),
234234
Unsigned.uint(0), // writeMask
235235
Unsigned.uint(0), // userWriteMask
236-
new Variant(initialValue),
236+
initialValue,
237237
objectType,
238238
ValueRanks.Scalar,
239239
null, // arrayDimensions

0 commit comments

Comments
 (0)