This is an automated email from the ASF dual-hosted git repository.
justinchen 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 9765ec84892 Pipe: Show "CONFIG_REGION" string instead of MIN_VALUE in
PipeTableResp (#16372)
9765ec84892 is described below
commit 9765ec84892864c47b0d957f376d88bed693adea
Author: VGalaxies <[email protected]>
AuthorDate: Tue Sep 9 19:00:56 2025 +0800
Pipe: Show "CONFIG_REGION" string instead of MIN_VALUE in PipeTableResp
(#16372)
---
.../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 ec596588b1e..34cbcdf7bdf 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
@@ -53,6 +53,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;
@@ -164,7 +166,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) {
