AMBARI-25882 Fix clusterId NPE error on service operation execution (#…

…3655) Co-authored-by: xiaoxiao <caixiaoliang@zto.com>
apache · Mar 6, 2023 · d81000f · d81000f
1 parent d26b730
commit d81000f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/ambari-server/src/main/java/org/apache/ambari/server/actionmanager/Stage.java b/ambari-server/src/main/java/org/apache/ambari/server/actionmanager/Stage.java
@@ -357,6 +357,7 @@ private ExecutionCommandWrapper addGenericExecutionCommand(String clusterName, S
     ExecutionCommand cmd = new ExecutionCommand();
     ExecutionCommandWrapper wrapper = ecwFactory.createFromCommand(cmd);
     hrc.setExecutionCommandWrapper(wrapper);
+    cmd.setClusterId(Long.toString(clusterId));
     cmd.setHostname(hostName);
     cmd.setClusterName(clusterName);
     cmd.setRequestAndStage(requestId, stageId);