org.apache.flink.testutils.junit

Annotation Type RetryOnFailure

@Retention(value=RUNTIME)
 @Target(value=METHOD)
public @interface RetryOnFailure

Annotation to use with RetryRule.

Add the RetryRule to your test and annotate tests with RetryOnFailure.

 public class YourTest {

      @Rule
     public RetryRule retryRule = new RetryRule();

      @Test
      @RetryOnFailure(times=1)
     public void yourTest() {
         // This will be retried 1 time (total runs 2) before failing the test.
         throw new Exception("Failing test");
     }
 }
 

Required Element Summary

Required Elements

Modifier and Type	Required Element and Description
int	times

Element Detail

times

public abstract int times