flink on yarn单节点
时间: 2023-08-08 21:08:59 浏览: 188
在Flink on Yarn的单节点模式下,可以使用以下命令来提交作业:
1. 进入到Flink的安装路径下。
2. 在命令行中使用以下命令提交作业:
```
bin/flink run -yd -m yarn-cluster -c <jar包内类名> -yDyarn.provided.lib.dirs="<hdfs:///flink依赖位置>" <jar包位置>
```
这个命令会将作业提交到Yarn集群上,并在集群上启动一个Flink任务。\[1\]
另外,如果你想在单节点模式下以detached方式运行作业,可以使用以下命令:
```
./bin/flink run -t yarn-per-job --detached -Dclassloader.check-leaked-classloader=false <jar包位置>
```
这个命令会在Yarn上以per-job cluster模式启动一个Flink任务,并且作业会在后台运行。\[2\]
如果你想停止当前启动的Yarn Session,可以执行以下命令:
```
cat /tmp/.yarn-properties-root | grep applicationID | cut -d'=' -f 2 | xargs -I {} yarn application -kill {}
```
这个命令会停止当前正在运行的Yarn Session。\[3\]
#### 引用[.reference_title]
- *1* [Flink 搭建 单点、HA、ON YARN与提交作业方法](https://blog.csdn.net/Mogeko1/article/details/128662565)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^control_2,239^v3^insert_chatgpt"}} ] [.reference_item]
- *2* *3* [flink on yarn](https://blog.csdn.net/az9996/article/details/128313011)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^control_2,239^v3^insert_chatgpt"}} ] [.reference_item]
[ .reference_list ]
阅读全文