(iotdb) branch master updated: Consensus pipe skip login (#17242)

[jiangtian]

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

jiangtian pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 449838f3608 Consensus pipe skip login (#17242)
449838f3608 is described below

commit 449838f3608c5f95194f55ebe02242f8eff17089
Author: Peng Junzhi <78788603+peng...@users.noreply.github.com>
AuthorDate: Wed Mar 4 09:29:25 2026 +0800

    Consensus pipe skip login (#17242)
---
 .../source/dataregion/IoTDBDataRegionSource.java   | 31 ++++++++++++----------
 1 file changed, 17 insertions(+), 14 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 1c510be959b..32e5c300f7d 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
@@ -22,6 +22,7 @@ package org.apache.iotdb.db.pipe.source.dataregion;
 import org.apache.iotdb.commons.conf.IoTDBConstant;
 import org.apache.iotdb.commons.consensus.DataRegionId;
 import org.apache.iotdb.commons.pipe.agent.task.PipeTaskAgent;
+import org.apache.iotdb.commons.pipe.agent.task.meta.PipeStaticMeta;
 import org.apache.iotdb.commons.pipe.config.constant.PipeSourceConstant;
 import org.apache.iotdb.commons.pipe.config.constant.SystemConstant;
 import 
org.apache.iotdb.commons.pipe.datastructure.pattern.IoTDBTreePatternOperations;
@@ -559,20 +560,22 @@ public class IoTDBDataRegionSource extends IoTDBSource {
 
   @Override
   protected void login(final @Nonnull String password) {
-    if (SessionManager.getInstance()
-            .login(
-                new InternalClientSession("Source_login_session_" + regionId),
-                userName,
-                password,
-                ZoneId.systemDefault().toString(),
-                SessionManager.CURRENT_RPC_VERSION,
-                IoTDBConstant.ClientVersion.V_1_0,
-                IClientSession.SqlDialect.TREE,
-                regionId >= 0)
-            .getCode()
-        != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-      throw new PipePasswordCheckException(
-          String.format("Failed to check password for pipe %s.", pipeName));
+    if (!pipeName.startsWith(PipeStaticMeta.CONSENSUS_PIPE_PREFIX)) {
+      if (SessionManager.getInstance()
+              .login(
+                  new InternalClientSession("Source_login_session_" + 
regionId),
+                  userName,
+                  password,
+                  ZoneId.systemDefault().toString(),
+                  SessionManager.CURRENT_RPC_VERSION,
+                  IoTDBConstant.ClientVersion.V_1_0,
+                  IClientSession.SqlDialect.TREE,
+                  regionId >= 0)
+              .getCode()
+          != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
+        throw new PipePasswordCheckException(
+            String.format("Failed to check password for pipe %s.", pipeName));
+      }
     }
   }