ensure you have java 6 or above and that the JAVA_HOME
environment variable is set.
download the latest flink binary here:
wget flink-XXXX.tar.gz
If you don't plan to work with Hadoop, pick the hadoop 1 version. Also, note the scala version you download, so you can add the correct maven dependencies in your programs.
start flink:
tar xzvf flink-XXXX.tar.gz
./flink/bin/start-local.sh
Flink is already configured to run locally.
To ensure flink is running, you can inspect the logs in flink/log/
or open the flink jobManager's interface running on http://localhost:8081
.
stop flink:
./flink/bin/stop-local.sh