This is an automated email from the ASF dual-hosted git repository.
jinsongzhou pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/amoro.git
The following commit(s) were added to refs/heads/master by this push:
new 004dbf8c6 [AMORO-3823] fix SparkOptimizer get applicationId failed
(#3826)
004dbf8c6 is described below
commit 004dbf8c64f61b3b48ab8fd3887463212350357c
Author: walt <[email protected]>
AuthorDate: Mon Oct 27 14:12:14 2025 +0800
[AMORO-3823] fix SparkOptimizer get applicationId failed (#3826)
fix SparkOptimizer get applicationId failed
---
.../java/org/apache/amoro/server/manager/SparkOptimizerContainer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/amoro-ams/src/main/java/org/apache/amoro/server/manager/SparkOptimizerContainer.java
b/amoro-ams/src/main/java/org/apache/amoro/server/manager/SparkOptimizerContainer.java
index 58d8c2f06..8609cf352 100644
---
a/amoro-ams/src/main/java/org/apache/amoro/server/manager/SparkOptimizerContainer.java
+++
b/amoro-ams/src/main/java/org/apache/amoro/server/manager/SparkOptimizerContainer.java
@@ -112,7 +112,7 @@ public class SparkOptimizerContainer extends
AbstractOptimizerContainer {
String startUpCmd = String.format("%s && %s", exportCmd, startUpArgs);
String[] cmd = {"/bin/sh", "-c", startUpCmd};
LOG.info("Starting spark optimizer using command : {}", startUpCmd);
- Process exec = Runtime.getRuntime().exec(cmd);
+ Process exec = new ProcessBuilder(cmd).redirectErrorStream(true).start();
Map<String, String> startUpStatesMap = Maps.newHashMap();
if (deployedOnKubernetes()) {
SparkOptimizerContainer.SparkConf sparkConf =