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-21168. Deleting host from cluster leaves Ambari in inconsistent state (intermittently) (magyari_sandor)
Date Tue, 06 Jun 2017 13:32:20 GMT
Repository: ambari
Updated Branches:
  refs/heads/branch-2.5 54ce6cca4 -> 9ed6d843e


AMBARI-21168. Deleting host from cluster leaves Ambari in inconsistent state (intermittently)
(magyari_sandor)


Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/9ed6d843
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/9ed6d843
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/9ed6d843

Branch: refs/heads/branch-2.5
Commit: 9ed6d843e929c37314560200555bbab48cc02e2b
Parents: 54ce6cc
Author: Sandor Magyari <smagyari@hortonworks.com>
Authored: Fri Jun 2 15:38:06 2017 +0200
Committer: Sandor Magyari <smagyari@hortonworks.com>
Committed: Tue Jun 6 15:31:47 2017 +0200

----------------------------------------------------------------------
 .../server/state/svccomphost/ServiceComponentHostImpl.java      | 5 +++++
 1 file changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ambari/blob/9ed6d843/ambari-server/src/main/java/org/apache/ambari/server/state/svccomphost/ServiceComponentHostImpl.java
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/java/org/apache/ambari/server/state/svccomphost/ServiceComponentHostImpl.java
b/ambari-server/src/main/java/org/apache/ambari/server/state/svccomphost/ServiceComponentHostImpl.java
index 4d034f6..0ff4dad 100644
--- a/ambari-server/src/main/java/org/apache/ambari/server/state/svccomphost/ServiceComponentHostImpl.java
+++ b/ambari-server/src/main/java/org/apache/ambari/server/state/svccomphost/ServiceComponentHostImpl.java
@@ -862,6 +862,7 @@ public class ServiceComponentHostImpl implements ServiceComponentHost
{
   }
 
   @Override
+  @Transactional
   public void setState(State state) {
     stateMachine.setCurrentState(state);
     HostComponentStateEntity stateEntity = getStateEntity();
@@ -890,6 +891,7 @@ public class ServiceComponentHostImpl implements ServiceComponentHost
{
   }
 
   @Override
+  @Transactional
   public void setVersion(String version) {
     HostComponentStateEntity stateEntity = getStateEntity();
     if (stateEntity != null) {
@@ -917,6 +919,7 @@ public class ServiceComponentHostImpl implements ServiceComponentHost
{
   }
 
   @Override
+  @Transactional
   public void setSecurityState(SecurityState securityState) {
     HostComponentStateEntity stateEntity = getStateEntity();
     if (stateEntity != null) {
@@ -966,6 +969,7 @@ public class ServiceComponentHostImpl implements ServiceComponentHost
{
    * @param upgradeState  the upgrade state
    */
   @Override
+  @Transactional
   public void setUpgradeState(UpgradeState upgradeState) {
     HostComponentStateEntity stateEntity = getStateEntity();
     if (stateEntity != null) {
@@ -994,6 +998,7 @@ public class ServiceComponentHostImpl implements ServiceComponentHost
{
 
 
   @Override
+  @Transactional
   public void handleEvent(ServiceComponentHostEvent event)
       throws InvalidStateTransitionException {
     if (LOG.isDebugEnabled()) {


Mime
View raw message