Class AbstractTestBaseJUnit4

  • Direct Known Subclasses:
    JavaProgramTestBaseJUnit4, MultipleProgramsTestBaseJUnit4

    @Deprecated
    public abstract class AbstractTestBaseJUnit4
    extends TestLogger
    Deprecated.
    Use AbstractTestBase instead.
    Base class for unit tests that run multiple tests and want to reuse the same Flink cluster. This saves a significant amount of time, since the startup and shutdown of the Flink clusters (including actor systems, etc) usually dominates the execution of the actual tests.

    To write a unit test against this test base, simply extend it and add one or more regular test methods and retrieve the StreamExecutionEnvironment from the context:

       @Test
       public void someTest() {
           ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
           // test code
           env.execute();
       }
    
       @Test
       public void anotherTest() {
           StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
           // test code
           env.execute();
       }