You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by ma...@apache.org on 2016/06/16 12:33:20 UTC
ambari git commit: AMBARI-17196. NPE in ambari-server.out when
cluster with kerberos is installed. (Daniel Gergely via magyari_sandor)
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 <dg...@hortonworks.com>
Authored: Thu Jun 16 14:30:01 2016 +0200
Committer: Sandor Magyari <sm...@hortonworks.com>
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());