modify errorOutput

orange475 · orange475 · commit d0311c8fc2ae · 2025-07-11T15:04:13.000-07:00
diff --git a/samza-core/src/main/java/org/apache/samza/container/host/PosixCommandBasedStatisticsGetter.java b/samza-core/src/main/java/org/apache/samza/container/host/PosixCommandBasedStatisticsGetter.java
@@ -62,7 +62,7 @@ private List<String> getAllCommandOutput(String[] cmdArray) throws IOException {
       // Consume error stream to prevent blocking
       StringBuilder errorOutput = new StringBuilder();
       while ((line = errorReader.readLine()) != null) {
-        log.error("stderr while running {}: {}", cmdArray, line);
+        errorOutput.append(line).append("\n");
       }
 
       if (!line.isEmpty()) {

Original file line number	Diff line number	Diff line change
`@@ -62,7 +62,7 @@ private List<String> getAllCommandOutput(String[] cmdArray) throws IOException {`
`62`	`62`	`// Consume error stream to prevent blocking`
`63`	`63`	`StringBuilder errorOutput = new StringBuilder();`
`64`	`64`	`while ((line = errorReader.readLine()) != null) {`
`65`		`- log.error("stderr while running {}: {}", cmdArray, line);`
	`65`	`+ errorOutput.append(line).append("\n");`
`66`	`66`	`}`
`67`	`67`
`68`	`68`	`if (!line.isEmpty()) {`