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 git@github.com: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.