Package org.apache.flink.test.util

Class MultipleProgramsTestBase

  • public class MultipleProgramsTestBase
extends AbstractTestBase
    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 ExecutionEnvironment from the context: 

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

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