org.apache.flink.testutils.junit.extensions.retry.strategy

Class RetryOnFailureStrategy

java.lang.Object

org.apache.flink.testutils.junit.extensions.retry.strategy.AbstractRetryStrategy

org.apache.flink.testutils.junit.extensions.retry.strategy.RetryOnFailureStrategy

All Implemented Interfaces:

RetryStrategy

public class RetryOnFailureStrategy
extends AbstractRetryStrategy

Retry strategy that retry fixed times.

Field Summary

Fields inherited from class org.apache.flink.testutils.junit.extensions.retry.strategy.AbstractRetryStrategy

hasNextAttempt, totalTimes

Constructor Summary

Constructors

Constructor and Description
RetryOnFailureStrategy(int retryTimes)

Method Summary

Modifier and Type	Method and Description
void	handleException(String testName, int attemptIndex, Throwable throwable) Handle the exception after the test execution.

Methods inherited from class org.apache.flink.testutils.junit.extensions.retry.strategy.AbstractRetryStrategy

hasNextAttempt, stopFollowingAttempts

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryOnFailureStrategy

public RetryOnFailureStrategy(int retryTimes)

Method Detail

handleException

public void handleException(String testName,
                            int attemptIndex,
                            Throwable throwable)
                     throws Throwable

Description copied from interface: RetryStrategy

Handle the exception after the test execution.

Parameters:

testName - the test name

attemptIndex - test attempt index that starts from 1

throwable - the throwable that the test case throws

Throws:

Throwable