This is an automated email from the ASF dual-hosted git repository. justinchen pushed a commit to branch fix-login in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 11018f1e3d1d49bc84865ceaf69118e2196cf5b8 Author: Caideyipi <[email protected]> AuthorDate: Sat Mar 21 23:02:20 2026 +0800 spt --- .../iotdb/db/pipe/source/dataregion/IoTDBDataRegionSource.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/IoTDBDataRegionSource.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/IoTDBDataRegionSource.java index a6d47bc1975..5653b81b48e 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/IoTDBDataRegionSource.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/IoTDBDataRegionSource.java @@ -561,7 +561,7 @@ public class IoTDBDataRegionSource extends IoTDBSource { @Override protected void login(final @Nonnull String password) { if (!pipeName.startsWith(PipeStaticMeta.CONSENSUS_PIPE_PREFIX)) { - final boolean useEncryptedPassword = regionId >= 0; + final boolean useEncryptedPassword = regionId >= 0; if (SessionManager.getInstance() .login( new InternalClientSession("Source_login_session_" + regionId), @@ -575,7 +575,9 @@ public class IoTDBDataRegionSource extends IoTDBSource { .getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) { throw new PipePasswordCheckException( - String.format("Failed to check password for pipe %s, useEncryptedPassword: %s", pipeName, useEncryptedPassword)); + String.format( + "Failed to check password for pipe %s, useEncryptedPassword: %s", + pipeName, useEncryptedPassword)); } } }
