@InterfaceStability.Unstable public class SlidingWindowRetryPolicy extends Object
Sliding window retry policy for relaunching a
Container
in Yarn.
Constructor and Description |
---|
SlidingWindowRetryPolicy(org.apache.hadoop.yarn.util.Clock clock) |
Modifier and Type | Method and Description |
---|---|
void |
setClock(org.apache.hadoop.yarn.util.Clock clock)
Sets the clock.
|
boolean |
shouldRetry(org.apache.hadoop.yarn.server.nodemanager.containermanager.container.SlidingWindowRetryPolicy.RetryContext retryContext,
int errorCode) |
protected void |
updateRetryContext(org.apache.hadoop.yarn.server.nodemanager.containermanager.container.SlidingWindowRetryPolicy.RetryContext retryContext)
Updates remaining retries and the restart time when
required in the retryContext.
|
public SlidingWindowRetryPolicy(org.apache.hadoop.yarn.util.Clock clock)
public boolean shouldRetry(org.apache.hadoop.yarn.server.nodemanager.containermanager.container.SlidingWindowRetryPolicy.RetryContext retryContext, int errorCode)
protected void updateRetryContext(org.apache.hadoop.yarn.server.nodemanager.containermanager.container.SlidingWindowRetryPolicy.RetryContext retryContext)
When failuresValidityInterval is > 0, it also removes time
entries from restartTimes
which are outside the validity
interval.
public void setClock(org.apache.hadoop.yarn.util.Clock clock)
clock
- clockCopyright © 2008–2023 Apache Software Foundation. All rights reserved.