(iotdb) branch dev/1.3 updated: [To dev/1.3] Pipe: Show "CONFIG_REGION" string instead of MIN_VALUE in PipeTableResp (#16372) (#16374)

[justinchen]

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

justinchen pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new c37cecaa45d [To dev/1.3] Pipe: Show "CONFIG_REGION" string instead of 
MIN_VALUE in PipeTableResp (#16372) (#16374)
c37cecaa45d is described below

commit c37cecaa45d79e6e86be1c6a88450a88deeece44
Author: VGalaxies <vgalax...@apache.org>
AuthorDate: Tue Sep 9 19:05:11 2025 +0800

    [To dev/1.3] Pipe: Show "CONFIG_REGION" string instead of MIN_VALUE in 
PipeTableResp (#16372) (#16374)
---
 .../consensus/response/pipe/task/PipeTableResp.java        | 14 +++++++++++++-
 1 file changed, 13 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/task/PipeTableResp.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/task/PipeTableResp.java
index 66323d4fbab..bb87e827d10 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/task/PipeTableResp.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/task/PipeTableResp.java
@@ -51,6 +51,8 @@ public class PipeTableResp implements DataSet {
   private final TSStatus status;
   private final List<PipeMeta> allPipeMeta;
 
+  private static final String CONFIG_REGION_ID = "CONFIG_REGION";
+
   public PipeTableResp(final TSStatus status, final List<PipeMeta> 
allPipeMeta) {
     this.status = status;
     this.allPipeMeta = allPipeMeta;
@@ -160,7 +162,17 @@ public class PipeTableResp implements DataSet {
         final Set<Integer> regionIds = entry.getValue();
         exceptionMessageBuilder
             .append("regionIds: ")
-            .append(regionIds)
+            .append(
+                regionIds.stream()
+                    .map(
+                        id -> {
+                          if (Objects.equals(Integer.MIN_VALUE, id)) {
+                            // handle config region id for user experience
+                            return CONFIG_REGION_ID;
+                          }
+                          return id.toString();
+                        })
+                    .collect(Collectors.toSet()))
             .append(", ")
             .append(exceptionMessage);
         if (++count < size) {