many-clean

Author: Caideyipi

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

@@ -19,7 +19,6 @@
 
 package org.apache.iotdb.db.pipe.sink.protocol.opcua.client;
 
-import org.apache.iotdb.commons.pipe.config.PipeConfig;
 import org.apache.iotdb.pipe.api.exception.PipeException;
 
 import org.bouncycastle.jce.provider.BouncyCastleProvider;
@@ -35,9 +34,6 @@
 import java.nio.file.Path;
 import java.nio.file.Paths;
 import java.security.Security;
-import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.TimeUnit;
 
 import static org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.Unsigned.uint;
 

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

@@ -52,6 +52,7 @@
 import org.eclipse.milo.opcua.stack.core.types.structured.VariableAttributes;
 
 import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.List;
 import java.util.Objects;
 import java.util.function.Predicate;
@@ -139,22 +140,39 @@ private void transferTabletRowForClientServerModel(
         if (!result.getStatusCode().equals(StatusCode.GOOD)
             && !(result.getStatusCode().getValue() == StatusCodes.Bad_NodeIdExists)) {
           throw new PipeException(
-              "Failed to create nodes after transfer data value, write status: "
-                  + writeStatus
-                  + ", creation status: "
-                  + addStatus);
+              "Failed to create nodes after transfer data value, creation status: "
+                  + addStatus
+                  + getErrorString(segments, opcDataType, value, writeStatus));
         }
       }
       writeStatus = client.writeValue(nodeId, dataValue).get();
       if (writeStatus.getValue() != StatusCode.GOOD.getValue()) {
         throw new PipeException(
-            "Failed to transfer dataValue after successfully created nodes, error: " + writeStatus);
+            "Failed to transfer dataValue after successfully created nodes"
+                + getErrorString(segments, opcDataType, value, writeStatus));
       }
-    } else if (writeStatus.getValue() != StatusCode.GOOD.getValue()){
-      throw new PipeException("Failed to transfer dataValue, error: " + writeStatus);
+    } else if (writeStatus.getValue() != StatusCode.GOOD.getValue()) {
+      throw new PipeException(
+          "Failed to transfer dataValue"
+              + getErrorString(segments, opcDataType, value, writeStatus));
     }
   }
 
+  private static String getErrorString(
+      final String[] segments,
+      final NodeId dataType,
+      final Object value,
+      final StatusCode writeStatus) {
+    return ", segments: "
+        + Arrays.toString(segments)
+        + ", dataType: "
+        + dataType
+        + ", value: "
+        + value
+        + ", error: "
+        + writeStatus;
+  }
+
   public List<AddNodesItem> getNodesToAdd(
       final String[] segments, final NodeId opcDataType, final Variant initialValue) {
     final List<AddNodesItem> addNodesItems = new ArrayList<>();