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 4ff533b84fc login
4ff533b84fc is described below
commit 4ff533b84fc5dc026c625b6e8b3706989d133b1d
Author: Caideyipi <[email protected]>
AuthorDate: Tue Feb 10 18:24:58 2026 +0800
login
---
.../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 6f06b9180ff..6bca2aa46ba 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
@@ -197,13 +197,15 @@ public class WriteBackSink implements PipeConnector {
}
// Check the password and its expiration
- SESSION_MANAGER.login(
- session,
- usernameString,
- passwordString,
- ZoneId.systemDefault().toString(),
- SessionManager.CURRENT_RPC_VERSION,
- IoTDBConstant.ClientVersion.V_1_0);
+ if (Objects.nonNull(passwordString)) {
+ SESSION_MANAGER.login(
+ session,
+ usernameString,
+ passwordString,
+ ZoneId.systemDefault().toString(),
+ SessionManager.CURRENT_RPC_VERSION,
+ IoTDBConstant.ClientVersion.V_1_0);
+ }
}
@Override
