pw

Author: Caideyipi

integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java

@@ -162,7 +162,7 @@ public void testOPCUAServerSink() throws Exception {
         Assert.fail();
       } catch (final Exception e) {
         Assert.assertEquals(
-            "org.apache.iotdb.jdbc.IoTDBSQLException: 1107: The existing server with tcp port 12686 and https port 8443's password test conflicts to the new password conflict, reject reusing.",
+            "org.apache.iotdb.jdbc.IoTDBSQLException: 1107: The existing server with tcp port 12686 and https port 8443's password **** conflicts to the new password ****, reject reusing.",
             e.getMessage());
       }
     }

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

@@ -324,8 +324,12 @@ void checkEquals(
     checkEquals("securityPolicies", this.securityPolicies, securityPolicies);
   }
 
-  private void checkEquals(final String attrName, final Object thisAttr, final Object thatAttr) {
+  private void checkEquals(final String attrName, Object thisAttr, Object thatAttr) {
     if (!Objects.equals(thisAttr, thatAttr)) {
+      if (attrName.equals("password")) {
+        thisAttr = "****";
+        thatAttr = "****";
+      }
       throw new PipeException(
           String.format(
               "The existing server with tcp port %s and https port %s's %s %s conflicts to the new %s %s, reject reusing.",