fix

Author: Caideyipi

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

@@ -331,14 +331,16 @@ private void customizeClient(final String nodeUrl, final PipeParameters paramete
     final IdentityProvider provider;
     final String userName =
         parameters.getStringByKeys(CONNECTOR_IOTDB_USER_KEY, SINK_IOTDB_USER_KEY);
+    final String password =
+        parameters.getStringOrDefault(
+            Arrays.asList(CONNECTOR_IOTDB_PASSWORD_KEY, SINK_IOTDB_PASSWORD_KEY),
+            CONNECTOR_IOTDB_PASSWORD_DEFAULT_VALUE);
     provider =
         Objects.nonNull(userName)
-            ? new UsernameProvider(
-                userName,
-                parameters.getStringByKeys(CONNECTOR_IOTDB_PASSWORD_KEY, SINK_IOTDB_PASSWORD_KEY))
+            ? new UsernameProvider(userName, password)
             : new AnonymousProvider();
     client = new IoTDBOpcUaClient(nodeUrl, policy, provider);
-    new ClientRunner(client).run();
+    new ClientRunner(client, password).run();
   }
 
   @Override

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

@@ -51,9 +51,11 @@ public class ClientRunner {
   private final CompletableFuture<OpcUaClient> future = new CompletableFuture<>();
 
   private final IoTDBOpcUaClient configurableUaClient;
+  private final String password;
 
-  public ClientRunner(IoTDBOpcUaClient configurableUaClient) {
+  public ClientRunner(final IoTDBOpcUaClient configurableUaClient, final String password) {
     this.configurableUaClient = configurableUaClient;
+    this.password = password;
   }
 
   private OpcUaClient createClient() throws Exception {
@@ -66,10 +68,11 @@ private OpcUaClient createClient() throws Exception {
 
     final File pkiDir = securityTempDir.resolve("pki").toFile();
 
-    logger.info("security dir: " + securityTempDir.toAbsolutePath());
+    logger.info("security dir: {}", securityTempDir.toAbsolutePath());
     logger.info("security pki dir: {}", pkiDir.getAbsolutePath());
 
-    final IoTDBKeyStoreLoaderClient loader = new IoTDBKeyStoreLoaderClient().load(securityTempDir);
+    final IoTDBKeyStoreLoaderClient loader =
+        new IoTDBKeyStoreLoaderClient().load(securityTempDir, password.toCharArray());
 
     final DefaultTrustListManager trustListManager = new DefaultTrustListManager(pkiDir);
 

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

@@ -42,21 +42,20 @@ class IoTDBKeyStoreLoaderClient {
       Pattern.compile("^(([01]?\\d\\d?|2[0-4]\\d|25[0-5])\\.){3}([01]?\\d\\d?|2[0-4]\\d|25[0-5])$");
 
   private static final String CLIENT_ALIAS = "client-ai";
-  private static final char[] PASSWORD = "root".toCharArray();
 
   private X509Certificate[] clientCertificateChain;
   private X509Certificate clientCertificate;
   private KeyPair clientKeyPair;
 
-  IoTDBKeyStoreLoaderClient load(Path baseDir) throws Exception {
+  IoTDBKeyStoreLoaderClient load(final Path baseDir, final char[] password) throws Exception {
     final KeyStore keyStore = KeyStore.getInstance("PKCS12");
 
     final Path serverKeyStore = baseDir.resolve("example-client.pfx");
 
     System.out.println("Loading KeyStore at " + serverKeyStore);
 
     if (!Files.exists(serverKeyStore)) {
-      keyStore.load(null, PASSWORD);
+      keyStore.load(null, password);
 
       final KeyPair keyPair = SelfSignedCertificateGenerator.generateRsaKeyPair(2048);
 
@@ -84,17 +83,17 @@ IoTDBKeyStoreLoaderClient load(Path baseDir) throws Exception {
       final X509Certificate certificate = builder.build();
 
       keyStore.setKeyEntry(
-          CLIENT_ALIAS, keyPair.getPrivate(), PASSWORD, new X509Certificate[] {certificate});
+          CLIENT_ALIAS, keyPair.getPrivate(), password, new X509Certificate[] {certificate});
       try (OutputStream out = Files.newOutputStream(serverKeyStore)) {
-        keyStore.store(out, PASSWORD);
+        keyStore.store(out, password);
       }
     } else {
       try (InputStream in = Files.newInputStream(serverKeyStore)) {
-        keyStore.load(in, PASSWORD);
+        keyStore.load(in, password);
       }
     }
 
-    final Key clientPrivateKey = keyStore.getKey(CLIENT_ALIAS, PASSWORD);
+    final Key clientPrivateKey = keyStore.getKey(CLIENT_ALIAS, password);
     if (clientPrivateKey instanceof PrivateKey) {
       clientCertificate = (X509Certificate) keyStore.getCertificate(CLIENT_ALIAS);