To run the end-to-end tests you will need a flink-dist
. You can build Flink from source or download from https://dist.apache.org/repos/dist/release/flink. For example, download flink-{FLINK_VERSION}-bin-scala_{SCALA_VERSION}.tgz
and extract, then find flink-dist-{FLINK_VERSION}.jar
in the lib
folder.
The end-to-end tests are disabled by default, to run them you can use the run-end-to-end-tests
maven profile.
Example command to run end-to-end tests:
mvn clean verify -Prun-end-to-end-tests -DdistDir=<path-to-dist>/flink-{FLINK_VERSION}/lib/flink-dist-{FLINK_VERSION}.jar
This test suite includes some integration tests that require access to AWS credentials. These tests run directly against AWS services.
These tests can be run by configuring the required AWS credentials, and using the run-aws-end-to-end-tests
maven profile. Example command:
FLINK_AWS_USER=<AWS_ACCESS_KEY_ID> FLINK_AWS_PASSWORD=<AWS_SECRET_ACCESS_KEY> mvn clean verify -Prun-aws-end-to-end-tests -DdistDir=<path-to-dist>/flink-{FLINK_VERSION}/lib/flink-dist-{FLINK_VERSION}.jar