# local mode

## Configure

Local mode is the simplest way to use Flink on Zeppelin. You just need to download Flink 1.10 or afterwards and then configure `FLINK_HOME`  and set `flink.execution.mode` as `local`

![](https://3876819094-files.gitbook.io/~/files/v0/b/gitbook-legacy-files/o/assets%2F-MEawVq7dzi4LX1-ifgT%2F-MEawgBGSy1RpJtvo66H%2F-MEb-pyku67SiQlqmOBZ%2Flocal.png?alt=media\&token=00e1f3fb-c618-40b4-93c6-90491fc4f071)

Local mode will launch a MiniCluster which consists of JobManager and one TaskManager that run in the current interpreter process via thread.&#x20;

## Basic WordCount

After the above configuration, you can just run the Flink tutorial note shipped with Zeppelin to verify whether the configuration is correct.

![](https://3876819094-files.gitbook.io/~/files/v0/b/gitbook-legacy-files/o/assets%2F-MEawVq7dzi4LX1-ifgT%2F-MGHR7CWDTjFsk4YRCMp%2F-MGHS0QpEobqPHfRCNbY%2Fimage.png?alt=media\&token=3902b66c-45e8-4c34-b33b-092b5defcf25)

## Port conflicts

In some cases, you might hit port conflict issue like following :

![](https://3876819094-files.gitbook.io/~/files/v0/b/gitbook-legacy-files/o/assets%2F-MEawVq7dzi4LX1-ifgT%2F-MG6UUzzsi7bLa2JSf3Z%2F-MG6V7YoxbMgohyx9YCH%2Fimage.png?alt=media\&token=7e6d8619-0050-45f4-9f69-281fc03ce755)

The reason is that JobManager in MIniCluster use port 8081 as its rest api port. And sometimes it is happened to be used by another process. Most likely is that you launched Flink standalone cluster. And the JobManager of Flink standalone cluster also use port 8081 by default. So just check whether you have launched a Flink standalone cluster (If so, just stop it), or whether other process is using port 8081.

## Video Tutorial

{% embed url="<https://youtu.be/A9yNtoXd4mg?list=PL4oy12nnS7FFtg3KV1iS5vDb0pTz12VcX>" %}

## Community

Join Zeppelin community to discuss with others&#x20;

{% embed url="<http://zeppelin.apache.org/community.html>" %}
