f

Author: Caideyipi

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

@@ -40,6 +40,7 @@
 import org.apache.iotdb.pipe.api.event.dml.insertion.TabletInsertionEvent;
 import org.apache.iotdb.pipe.api.exception.PipeException;
 
+import org.apache.tsfile.common.conf.TSFileConfig;
 import org.apache.tsfile.utils.Pair;
 import org.apache.tsfile.write.record.Tablet;
 import org.eclipse.milo.opcua.sdk.client.api.identity.AnonymousProvider;
@@ -347,7 +348,7 @@ private void customizeClient(final String nodeUrl, final PipeParameters paramete
                 Arrays.asList(CONNECTOR_OPC_UA_SECURITY_DIR_KEY, SINK_OPC_UA_SECURITY_DIR_KEY),
                 CONNECTOR_OPC_UA_SECURITY_DIR_DEFAULT_VALUE
                     + File.separatorChar
-                    + UUID.fromString(nodeUrl)));
+                    + UUID.nameUUIDFromBytes(nodeUrl.getBytes(TSFileConfig.STRING_CHARSET))));
 
     client = new IoTDBOpcUaClient(nodeUrl, policy, provider);
     new ClientRunner(client, securityDir, password).run();

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

@@ -123,10 +123,10 @@ public void run() {
         future.get(
             PipeConfig.getInstance().getPipeConnectorHandshakeTimeoutMs(), TimeUnit.MICROSECONDS);
       } catch (final Exception e) {
-        throw new PipeException("Error running client example.", e);
+        throw new PipeException("Error running client example: " + e.getMessage());
       }
     } catch (final Exception e) {
-      throw new PipeException("Error getting client.", e);
+      throw new PipeException("Error getting client: " + e.getMessage());
     }
   }
 }