From be548425a1c54c6efca82ea325923ddc80a6bd0e Mon Sep 17 00:00:00 2001
From: Mark Tsai <mark102555@gmail.com>
Date: Sat, 22 Aug 2026 23:43:50 +0800
Subject: [PATCH] HDDS-16253. Recon getPipelines() never returns pipelines due
 to missing terminal stream operation

---
 .../recon/spi/impl/ReconContainerMetadataManagerImpl.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/spi/impl/ReconContainerMetadataManagerImpl.java b/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/spi/impl/ReconContainerMetadataManagerImpl.java
index dc037e4aec8e..6e36cbbf6a4f 100644
--- a/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/spi/impl/ReconContainerMetadataManagerImpl.java
+++ b/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/spi/impl/ReconContainerMetadataManagerImpl.java
@@ -514,10 +514,10 @@ private List<Pipeline> getPipelines(ContainerKeyPrefix containerKeyPrefix)
     }
     List<Pipeline> pipelines = new ArrayList<>();
     if (null != omKeyInfo) {
-      omKeyInfo.getKeyLocationVersions().stream().map(
+      omKeyInfo.getKeyLocationVersions().forEach(
           omKeyLocationInfoGroup ->
-              omKeyLocationInfoGroup.getLocationList()
-                  .stream().map(omKeyLocationInfo -> pipelines.add(
+              omKeyLocationInfoGroup.getLocationList().forEach(
+                  omKeyLocationInfo -> pipelines.add(
                       omKeyLocationInfo.getPipeline())));
     }
     return pipelines;