This project illustrates how to test Apache Flink applications on different levels of the testing pyramid. Additional content on this topic can be also found in the corresponding part of the Apache Flink documentation.
The projects currently contains examples for
- unit tests of Stateless UDFs
- unit tests of Stateful UDFs incl. WatermarkAssigners
- integration tests for complete Flink Jobs
Simply checkout the repository and run the the gradle build with the included gradle wrapper:
git clone [email protected]:knaufk/flink-testing-pyramide.git
cd flink-testing-pyramide
./gradlew build
Licensed under the Apache License, Version 2.0: https://www.apache.org/licenses/LICENSE-2.0
Apache Flink, Flink®, Apache®, the squirrel logo, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.