This repository contains sets of micro benchmarks designed to run on single machine to help Apache Flink's developers assess performance implications of their changes.

The main methods defined in the various classes (test cases) are using jmh michro benchmark suite to define runners to execute those test cases. You can either execute whole benchmark suite (which takes ~1hour) at once:

mvn -Dflink.version=1.5.0 clean install exec:exec

or if you want to execute just one benchmark, the best approach is to execute selected main function manually. For example from your IDE (hint there is a plugin for Intellij IDEA). In that case don't forget about selecting flink.version, default value for the property is defined in pom.xml.