Repository: ambari Updated Branches: refs/heads/trunk adacd7315 -> cfcedaf3f
AMBARI-17196. NPE in ambari-server.out when cluster with kerberos is installed. (Daniel Gergely via magyari_sandor) Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/cfcedaf3 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/cfcedaf3 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/cfcedaf3 Branch: refs/heads/trunk Commit: cfcedaf3fac7a7cd7f20c01651ceedd4cc7cc72c Parents: adacd73 Author: Daniel Gergely <[email protected]> Authored: Thu Jun 16 14:30:01 2016 +0200 Committer: Sandor Magyari <[email protected]> Committed: Thu Jun 16 14:30:01 2016 +0200 ---------------------------------------------------------------------- .../java/org/apache/ambari/server/topology/HostRequest.java | 8 ++++++++ 1 file changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/cfcedaf3/ambari-server/src/main/java/org/apache/ambari/server/topology/HostRequest.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/java/org/apache/ambari/server/topology/HostRequest.java b/ambari-server/src/main/java/org/apache/ambari/server/topology/HostRequest.java index 99d7eec..d001f54 100644 --- a/ambari-server/src/main/java/org/apache/ambari/server/topology/HostRequest.java +++ b/ambari-server/src/main/java/org/apache/ambari/server/topology/HostRequest.java @@ -505,6 +505,10 @@ public class HostRequest implements Comparable<HostRequest> { List<ShortTaskStatus> underlyingTasks = response.getTasks(); for (ShortTaskStatus task : underlyingTasks) { Long logicalInstallTaskId = logicalTaskMap.get(this).get(task.getRole()); + if(logicalInstallTaskId == null) { + LOG.info("Skipping physical install task registering, because component {} cannot be found", task.getRole()); + continue; + } //todo: for now only one physical task per component long taskId = task.getTaskId(); registerPhysicalTaskId(logicalInstallTaskId, taskId); @@ -547,6 +551,10 @@ public class HostRequest implements Comparable<HostRequest> { for (ShortTaskStatus task : underlyingTasks) { String component = task.getRole(); Long logicalStartTaskId = logicalTaskMap.get(this).get(component); + if(logicalStartTaskId == null) { + LOG.info("Skipping physical start task registering, because component {} cannot be found", task.getRole()); + continue; + } // for now just set on outer map registerPhysicalTaskId(logicalStartTaskId, task.getTaskId());
