This documentation is for an out-of-date version of Apache Flink. We recommend you use the latest stable version.
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:
Download the 1.13.6 release and un-tar it.
$ tar -xzf flink-1.13.6-bin-scala_2.11.tgz $ cd flink-1.13.6-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 (nymph,1) (in,3) (thy,1) (orisons,1) (be,4) (all,2) (my,1) (sins,1) (remember,1) (d,4)
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.