flink-testing-pyramid icon indicating copy to clipboard operation
flink-testing-pyramid copied to clipboard

Example of a tested Apache Flink application.

Apache Flink Testing Pyramid

Introduction

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

Build

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

License

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.