(iotdb) branch IT-op updated: Update IoTDBPipePermissionIT.java

[justinchen]

This is an automated email from the ASF dual-hosted git repository.

Caideyipi pushed a commit to branch IT-op
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/IT-op by this push:
     new 280473c4583 Update IoTDBPipePermissionIT.java
280473c4583 is described below

commit 280473c458308444ff635c38b380c3a98eeaa088
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Mon May 18 17:08:29 2026 +0800

    Update IoTDBPipePermissionIT.java
---
 .../iotdb/pipe/it/dual/treemodel/manual/IoTDBPipePermissionIT.java   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/manual/IoTDBPipePermissionIT.java
 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/manual/IoTDBPipePermissionIT.java
index cf6eaf6a9c5..d43bb6564b1 100644
--- 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/manual/IoTDBPipePermissionIT.java
+++ 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/manual/IoTDBPipePermissionIT.java
@@ -590,12 +590,16 @@ public class IoTDBPipePermissionIT extends 
AbstractPipeDualTreeModelManualIT {
         "count(root.vehicle.plane.pressure),",
         Collections.singleton("1,"));
 
+    // After restart, the pipe keeps retrying with the stale password and may 
trigger login lock.
+    statement.execute("alter user thulab account unlock");
+
     try {
       statement.execute("alter pipe a2b modify source ('password'='fake')");
     } catch (final SQLException e) {
       Assert.assertEquals("801: Failed to check password for pipe a2b.", 
e.getMessage());
     }
 
+    statement.execute("alter user thulab account unlock");
     statement.execute("alter pipe a2b modify source 
('password'='newST@ongPassword')");
 
     // Test empty alter
@@ -620,6 +624,7 @@ public class IoTDBPipePermissionIT extends 
AbstractPipeDualTreeModelManualIT {
     statement = connection.createStatement();
     TestUtils.executeNonQuery(
         senderEnv, "insert into root.vehicle.plane(temperature, pressure) 
values (36.5, 1103)");
+    statement.execute("alter user thulab account unlock");
     statement.execute("alter user thulab set password 'newST@ongPassword'");
     statement.execute("alter pipe a2b");