org.apache.ambari.server.state.services

Class RetryUpgradeActionService

java.lang.Object

com.google.common.util.concurrent.AbstractScheduledService

org.apache.ambari.server.state.services.RetryUpgradeActionService

All Implemented Interfaces:

com.google.common.util.concurrent.Service

public class RetryUpgradeActionService
extends com.google.common.util.concurrent.AbstractScheduledService

Monitors commands during Stack Upgrade that are in a HOLDING_* failed because they failed in order to retry them automatically until they exceed a certain threshold of retry time.

Nested Class Summary

Nested classes/interfaces inherited from class com.google.common.util.concurrent.AbstractScheduledService

com.google.common.util.concurrent.AbstractScheduledService.CustomScheduler, com.google.common.util.concurrent.AbstractScheduledService.Scheduler

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Constructor Summary

Constructors

Constructor and Description
RetryUpgradeActionService()

Method Summary

Modifier and Type	Method and Description
void	retryHoldingCommandsInRequest(Long requestId) Retry HOLDING_* tasks for the given Request Id if the tasks meet certain criteria.
protected void	runOneIteration() Analyze each cluster for any active upgrades and attempt to retry any actions in a HOLDING_* status.
protected com.google.common.util.concurrent.AbstractScheduledService.Scheduler	scheduler()
void	setMaxTimeout(int mins)
protected void	startUp() Only run if the timeout mins is positive.

Methods inherited from class com.google.common.util.concurrent.AbstractScheduledService

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, executor, failureCause, isRunning, serviceName, shutDown, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

RetryUpgradeActionService

public RetryUpgradeActionService()

Method Detail

scheduler

protected com.google.common.util.concurrent.AbstractScheduledService.Scheduler scheduler()

Specified by:

scheduler in class com.google.common.util.concurrent.AbstractScheduledService

startUp

protected void startUp()
                throws Exception

Only run if the timeout mins is positive.

Overrides:

startUp in class com.google.common.util.concurrent.AbstractScheduledService

Throws:

Exception

setMaxTimeout

public void setMaxTimeout(int mins)

runOneIteration

protected void runOneIteration()
                        throws Exception

Analyze each cluster for any active upgrades and attempt to retry any actions in a HOLDING_* status.

Specified by:

runOneIteration in class com.google.common.util.concurrent.AbstractScheduledService

Throws:

Exception

retryHoldingCommandsInRequest

public void retryHoldingCommandsInRequest(Long requestId)

Retry HOLDING_* tasks for the given Request Id if the tasks meet certain criteria.

Parameters:

requestId - Request Id to search tasks for.