Local Installation
This documentation is for an unreleased version of Apache Flink. We recommend you use the latest stable version.

Local Installation #

NOTE: The Apache Flink community only publishes official builds for released versions of Apache Flink.

Since you are currently looking at the latest SNAPSHOT version of the documentation, all version references below will not work. Please switch the documentation to the latest released version via the release picker which you find on the left side below the menu.

Follow these few steps to download the latest stable versions and get started.

Step 1: Download #

To be able to run Flink, the only requirement is to have a working Java 8 or 11 installation. You can check the correct installation of Java by issuing the following command:

java -version

Download the 1.13-SNAPSHOT release and un-tar it.

$ tar -xzf flink-1.13-SNAPSHOT-bin-scala_2.11.tgz
$ cd flink-1.13-SNAPSHOT-bin-scala_2.11

Step 2: Start a Cluster #

Flink ships with a single bash script to start a local cluster.

$ ./bin/start-cluster.sh
Starting cluster.
Starting standalonesession daemon on host.
Starting taskexecutor daemon on host.

Step 3: Submit a Job #

Releases of Flink come with a number of example Jobs. You can quickly deploy one of these applications to the running cluster.

$ ./bin/flink run examples/streaming/WordCount.jar
$ tail log/flink-*-taskexecutor-*.out
  (to,1)
  (be,1)
  (or,1)
  (not,1)
  (to,2)
  (be,2)

Additionally, you can check Flink’s Web UI to monitor the status of the Cluster and running Job.

Step 4: Stop the Cluster #

When you are finished you can quickly stop the cluster and all running components.

$ ./bin/stop-cluster.sh