Local Installation

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:

  1. java -version

Download the 1.12.0 release and un-tar it.

  1. $ tar -xzf flink-1.12.0-bin-scala_2.11.tgz
  2. $ cd flink-1.12.0-bin-scala_2.11

Step 2: Start a Cluster

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

  1. $ ./bin/start-cluster.sh
  2. Starting cluster.
  3. Starting standalonesession daemon on host.
  4. 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.

  1. $ ./bin/flink run examples/streaming/WordCount.jar
  2. $ tail log/flink-*-taskexecutor-*.out
  3.   (to,1)
  4.   (be,1)
  5.   (or,1)
  6.   (not,1)
  7.   (to,2)
  8.   (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.

  1. $ ./bin/stop-cluster.sh