Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 24AB4200D5E for ; Fri, 8 Dec 2017 20:22:44 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 23599160C0D; Fri, 8 Dec 2017 19:22:44 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 08AED160C29 for ; Fri, 8 Dec 2017 20:22:42 +0100 (CET) Received: (qmail 49966 invoked by uid 500); 8 Dec 2017 19:22:41 -0000 Mailing-List: contact commits-help@ambari.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: ambari-dev@ambari.apache.org Delivered-To: mailing list commits@ambari.apache.org Received: (qmail 49718 invoked by uid 99); 8 Dec 2017 19:22:41 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 08 Dec 2017 19:22:41 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 5079BF6175; Fri, 8 Dec 2017 19:22:40 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: rlevas@apache.org To: commits@ambari.apache.org Date: Fri, 08 Dec 2017 19:22:50 -0000 Message-Id: In-Reply-To: <3bdcb9b392e8408194332ff2ff3c7f2a@git.apache.org> References: <3bdcb9b392e8408194332ff2ff3c7f2a@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [11/21] ambari git commit: AMBARI-22605. Tez service check hangs when adding service. (mpapirkovskyy) archived-at: Fri, 08 Dec 2017 19:22:44 -0000 AMBARI-22605. Tez service check hangs when adding service. (mpapirkovskyy) Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/a9c3bf56 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/a9c3bf56 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/a9c3bf56 Branch: refs/heads/branch-feature-AMBARI-20859 Commit: a9c3bf56a64448708dde677d063619d4c71e3492 Parents: 2460ea1 Author: Myroslav Papirkovskyi Authored: Wed Dec 6 18:10:53 2017 +0200 Committer: Myroslav Papirkovskyi Committed: Thu Dec 7 17:37:33 2017 +0200 ---------------------------------------------------------------------- .../AmbariManagementControllerImpl.java | 6 +++++ .../upgrade/HostVersionOutOfSyncListener.java | 24 ++++++++++++++++++++ 2 files changed, 30 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/a9c3bf56/ambari-server/src/main/java/org/apache/ambari/server/controller/AmbariManagementControllerImpl.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/java/org/apache/ambari/server/controller/AmbariManagementControllerImpl.java b/ambari-server/src/main/java/org/apache/ambari/server/controller/AmbariManagementControllerImpl.java index 232737c..198b617 100644 --- a/ambari-server/src/main/java/org/apache/ambari/server/controller/AmbariManagementControllerImpl.java +++ b/ambari-server/src/main/java/org/apache/ambari/server/controller/AmbariManagementControllerImpl.java @@ -3031,6 +3031,12 @@ public class AmbariManagementControllerImpl implements AmbariManagementControlle continue; } + if (StringUtils.isBlank(stage.getHostParamsStage())) { + RepositoryVersionEntity repositoryVersion = component.getDesiredRepositoryVersion(); + stage.setHostParamsStage(StageUtils.getGson().toJson( + customCommandExecutionHelper.createDefaultHostParams(cluster, repositoryVersion.getStackId()))); + } + customCommandExecutionHelper.addServiceCheckAction(stage, clientHost, smokeTestRole, nowTimestamp, serviceName, componentName, null, false, false); } http://git-wip-us.apache.org/repos/asf/ambari/blob/a9c3bf56/ambari-server/src/main/java/org/apache/ambari/server/events/listeners/upgrade/HostVersionOutOfSyncListener.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/java/org/apache/ambari/server/events/listeners/upgrade/HostVersionOutOfSyncListener.java b/ambari-server/src/main/java/org/apache/ambari/server/events/listeners/upgrade/HostVersionOutOfSyncListener.java index 4ce855d..4b3e42a 100644 --- a/ambari-server/src/main/java/org/apache/ambari/server/events/listeners/upgrade/HostVersionOutOfSyncListener.java +++ b/ambari-server/src/main/java/org/apache/ambari/server/events/listeners/upgrade/HostVersionOutOfSyncListener.java @@ -129,6 +129,14 @@ public class HostVersionOutOfSyncListener { // stack, but become versionAdvertised in some future (installed, but not yet upgraded to) stack String serviceName = event.getServiceName(); String componentName = event.getComponentName(); + + // Skip lookup if stack does not contain the component + if (!ami.get().isValidServiceComponent(hostStackId.getStackName(), + hostStackId.getStackVersion(), serviceName, componentName)) { + LOG.debug("Component not found is host stack, stack={}, version={}, service={}, component={}", + hostStackId.getStackName(), hostStackId.getStackVersion(), serviceName, componentName); + continue; + } ComponentInfo component = ami.get().getComponent(hostStackId.getStackName(), hostStackId.getStackVersion(), serviceName, componentName); @@ -215,6 +223,14 @@ public class HostVersionOutOfSyncListener { Collection hostComponents = host.getHostComponentDesiredStateEntities(); for (HostComponentDesiredStateEntity hostComponent : hostComponents) { + // Skip lookup if stack does not contain the component + if (!ami.get().isValidServiceComponent(stackId.getStackName(), + stackId.getStackVersion(), hostComponent.getServiceName(), hostComponent.getComponentName())) { + LOG.debug("Component not found is host stack, stack={}, version={}, service={}, component={}", + stackId.getStackName(), stackId.getStackVersion(), + hostComponent.getServiceName(), hostComponent.getComponentName()); + continue; + } ComponentInfo ci = ami.get().getComponent(stackId.getStackName(), stackId.getStackVersion(), hostComponent.getServiceName(), hostComponent.getComponentName()); @@ -260,6 +276,14 @@ public class HostVersionOutOfSyncListener { String serviceName = event.getServiceName(); for (ServiceComponent comp : affectedHosts.get(hostName)) { String componentName = comp.getName(); + + // Skip lookup if stack does not contain the component + if (!ami.get().isValidServiceComponent(repositoryVersion.getStackName(), + repositoryVersion.getStackVersion(), serviceName, componentName)) { + LOG.debug("Component not found is host stack, stack={}, version={}, service={}, component={}", + repositoryVersion.getStackName(), repositoryVersion.getStackVersion(), serviceName, componentName); + continue; + } ComponentInfo component = ami.get().getComponent(repositoryVersion.getStackName(), repositoryVersion.getStackVersion(), serviceName, componentName); if (component.isVersionAdvertised()) {