This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch login-restart
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/login-restart by this push:
new d2966a4aeb5 expr
d2966a4aeb5 is described below
commit d2966a4aeb5fd097cd902ff472641477c6698898
Author: Caideyipi <[email protected]>
AuthorDate: Tue Feb 10 18:19:28 2026 +0800
expr
---
.../db/pipe/sink/protocol/writeback/WriteBackSink.java | 16 +++++++++-------
1 file changed, 9 insertions(+), 7 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/writeback/WriteBackSink.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/writeback/WriteBackSink.java
index 94dc94022c5..6f06b9180ff 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/writeback/WriteBackSink.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/writeback/WriteBackSink.java
@@ -194,14 +194,16 @@ public class WriteBackSink implements PipeConnector {
if (SESSION_MANAGER.getCurrSession() == null) {
SESSION_MANAGER.registerSession(session);
- SESSION_MANAGER.login(
- session,
- usernameString,
- passwordString,
- ZoneId.systemDefault().toString(),
- SessionManager.CURRENT_RPC_VERSION,
- IoTDBConstant.ClientVersion.V_1_0);
}
+
+ // Check the password and its expiration
+ SESSION_MANAGER.login(
+ session,
+ usernameString,
+ passwordString,
+ ZoneId.systemDefault().toString(),
+ SessionManager.CURRENT_RPC_VERSION,
+ IoTDBConstant.ClientVersion.V_1_0);
}
@Override
