Repository: ambari Updated Branches: refs/heads/trunk bb5c8975f -> b38be7fc9
AMBARI-13683: Express Upgrade: HBASE upgrade fails during EU for HDP-2.1-> HDP-2.3 (jluniya) Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/b38be7fc Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/b38be7fc Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/b38be7fc Branch: refs/heads/trunk Commit: b38be7fc9abcd72ccc1cbe61b7ba0d071a213f0b Parents: bb5c897 Author: Jayush Luniya <jlun...@hortonworks.com> Authored: Mon Nov 2 22:05:49 2015 -0800 Committer: Jayush Luniya <jlun...@hortonworks.com> Committed: Mon Nov 2 22:05:49 2015 -0800 ---------------------------------------------------------------------- .../ambari/server/api/handlers/CreateHandler.java | 2 +- .../internal/ClusterStackVersionResourceProvider.java | 12 +++++++----- 2 files changed, 8 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/b38be7fc/ambari-server/src/main/java/org/apache/ambari/server/api/handlers/CreateHandler.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/java/org/apache/ambari/server/api/handlers/CreateHandler.java b/ambari-server/src/main/java/org/apache/ambari/server/api/handlers/CreateHandler.java index c1bd91b..9690bcd 100644 --- a/ambari-server/src/main/java/org/apache/ambari/server/api/handlers/CreateHandler.java +++ b/ambari-server/src/main/java/org/apache/ambari/server/api/handlers/CreateHandler.java @@ -54,7 +54,7 @@ public class CreateHandler extends BaseManagementHandler { result = new ResultImpl(new ResultStatus(ResultStatus.STATUS.NOT_FOUND, e.getMessage())); } catch (SystemException e) { if (LOG.isErrorEnabled()) { - LOG.error("Caught a system exception while attempting to create a resource", e.getMessage()); + LOG.error("Caught a system exception while attempting to create a resource: {}", e.getMessage()); } result = new ResultImpl(new ResultStatus(ResultStatus.STATUS.SERVER_ERROR, e.getMessage())); } catch (ResourceAlreadyExistsException e) { http://git-wip-us.apache.org/repos/asf/ambari/blob/b38be7fc/ambari-server/src/main/java/org/apache/ambari/server/controller/internal/ClusterStackVersionResourceProvider.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/java/org/apache/ambari/server/controller/internal/ClusterStackVersionResourceProvider.java b/ambari-server/src/main/java/org/apache/ambari/server/controller/internal/ClusterStackVersionResourceProvider.java index adae105..22212bf 100644 --- a/ambari-server/src/main/java/org/apache/ambari/server/controller/internal/ClusterStackVersionResourceProvider.java +++ b/ambari-server/src/main/java/org/apache/ambari/server/controller/internal/ClusterStackVersionResourceProvider.java @@ -383,10 +383,10 @@ public class ClusterStackVersionResourceProvider extends AbstractControllerResou // Create next stage String stageName; if (batchCount > 1) { - stageName = INSTALL_PACKAGES_FULL_NAME; - } else { stageName = String.format(INSTALL_PACKAGES_FULL_NAME + ". Batch %d of %d", batchId, batchCount); + } else { + stageName = INSTALL_PACKAGES_FULL_NAME; } Stage stage = stageFactory.createNew(req.getId(), "/tmp/ambari", cluster.getClusterName(), @@ -414,7 +414,6 @@ public class ClusterStackVersionResourceProvider extends AbstractControllerResou } else { directTransitions.add(host); } - } } @@ -550,8 +549,11 @@ public class ClusterStackVersionResourceProvider extends AbstractControllerResou componentInfo = ami.getComponent(stackId.getStackName(), stackId.getStackVersion(), component.getServiceName(), component.getServiceComponentName()); } catch (AmbariException e) { - throw new SystemException(String.format("Exception while accessing component %s of service %s for stack %s", - component.getServiceName(), component.getServiceComponentName(), stackId)); + // It is possible that the component has been removed from the new stack + // (example: STORM_REST_API has been removed from HDP-2.2) + LOG.warn(String.format("Exception while accessing component %s of service %s for stack %s", + component.getServiceComponentName(), component.getServiceName(), stackId)); + continue; } if (componentInfo.isVersionAdvertised()) { return true;