# yarn mode

Yarn mode means Zeppelin will create a flink session cluster in yarn cluster. Then you can submit flink jobs to this flink session cluster.

## Configuration

* Besides `FLINK_HOME` and `flink.execution.mode`, you also need to configure `HADOOP_CONF_DIR`, and make sure the zeppelin machine can access hadoop cluster.
* Make sure zeppelin machine install hadoop client and `hadoop` command on the `PATH`. Because flink is not shipped with hadoop by default (although you can download `flink-shaded-hadoop` and put it under flink lib, but it is not the recommended approach).  Zeppelin will run command `hadoop classpath` underneath, and put them on the classpath of flink interpreter process.

![](https://3876819094-files.gitbook.io/~/files/v0/b/gitbook-legacy-files/o/assets%2F-MEawVq7dzi4LX1-ifgT%2F-MG6XDATVqW0VUSqa3dR%2F-MG6XW9S9VPKIw3hrhAu%2Fimage.png?alt=media\&token=a1e398cb-f038-4614-bcef-09405228f5b0)

After these configuration, you can run wordcount example to verify it. And you will see a flink session cluster launched in yarn as following.

![](https://3876819094-files.gitbook.io/~/files/v0/b/gitbook-legacy-files/o/assets%2F-MEawVq7dzi4LX1-ifgT%2F-MIDzzrcHGb5ryrhVxBt%2F-MIE0iQA00BDx4shcP3j%2Fimage.png?alt=media\&token=136f02e6-5987-4941-9dc8-942c9ce4c40f)

## Video Tutorial

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

## Community

Join Zeppelin community to discuss with others&#x20;

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


---

# Agent Instructions: Querying This Documentation

If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question.

Perform an HTTP GET request on the current page URL with the `ask` query parameter:

```
GET https://zjffdu.gitbook.io/flink-on-zeppelin/execution-mode/yarn-mode.md?ask=<question>
```

The question should be specific, self-contained, and written in natural language.
The response will contain a direct answer to the question and relevant excerpts and sources from the documentation.

Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.