ambari-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From magyari_san...@apache.org
Subject ambari git commit: AMBARI-17196. NPE in ambari-server.out when cluster with kerberos is installed. (Daniel Gergely via magyari_sandor)
Date Thu, 16 Jun 2016 12:38:22 GMT
Repository: ambari
Updated Branches:
  refs/heads/branch-2.4 27a01bbfc -> 5e6a94c89


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/5e6a94c8
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/5e6a94c8
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/5e6a94c8

Branch: refs/heads/branch-2.4
Commit: 5e6a94c89511b20223bf761aae62b718a40d3cb8
Parents: 27a01bb
Author: Daniel Gergely <dgergely@hortonworks.com>
Authored: Thu Jun 16 14:30:01 2016 +0200
Committer: Sandor Magyari <smagyari@hortonworks.com>
Committed: Thu Jun 16 14:35:03 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/5e6a94c8/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());
 


Mime
View raw message