org.apache.flink.streaming.tests

Class FailureEnricherTestProgram

java.lang.Object

org.apache.flink.streaming.tests.FailureEnricherTestProgram

public class FailureEnricherTestProgram
extends Object

End-to-end test program for verifying that the JobManagerOptions.FAILURE_ENRICHERS_LIST. We test this by creating a CustomTestFailureEnricherFactory and CustomTestFailureEnricher which will add label for the failure. And we will add this jar to plugin/failure-enricher package, then submit this job and verify the exceptions through restful api in test_failure_enricher.sh script.

Constructor Summary

Constructors

Constructor and Description
FailureEnricherTestProgram()

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args)

Methods inherited from class java.lang.Object

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

Constructor Detail

FailureEnricherTestProgram

public FailureEnricherTestProgram()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception