Get a local Flink cluster up and running in a few simple steps.
Flink runs on Linux, Mac OS X, and Windows. 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:
If you have Java 8, the output will look something like this:
Clone the source code from one of our repositories, e.g.:
bin folder of your Java Runtime Environment must be included in Window’s
Follow this guide to add Java to the
After that, you need to open a second terminal to run jobs using
Check the Dispatcher’s web frontend at http://localhost:8081 and make sure everything is up and running. The web frontend should report a single available TaskManager instance.
You can also verify that the system is running by checking the log files in the
If you are installing Flink from the git repository and you are using the Windows git shell, Cygwin can produce a failure similar to this one:
This error occurs because git is automatically transforming UNIX line endings to Windows style line endings when running in Windows. The problem is that Cygwin can only deal with UNIX style line endings. The solution is to adjust the Cygwin settings to deal with the correct line endings by following these three steps:
Start a Cygwin shell.
Determine your home directory by entering
This will return a path under the Cygwin root path.
.bash_profilein the home directory and append the following: (If the file does not exist you will have to create it)
Save the file and open a new bash shell.
To stop Flink when you’re done type:
You can terminate the processes via CTRL-C in the spawned shell windows.