java Flink（五） Flink standalone模式下部署以及使用，提交任务、关闭任务、运行任务等

女爷i 2022-11-12 13:42 660阅读 0赞

**首先安装包在上个文章可以下载，下载完毕放在我们Linux机器上，解压。**

1、给bin目录配置权限，bin目录下都是sh文件，配置权限

2、修改配置文件 conf/flink-conf.yaml

修改task槽点，就是可以运行多少个任务（每个任务可能需要多个slots），如果任务slots超过了配置上线就会一直等待然后退出

一般修改为本机CPU数，我是32C，所以修改为32

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNzcxNTY3_size_16_color_FFFFFF_t_70][]

3、运行Flink

![20210324101645382.png][]

4、查看运行状态

![20210324101911996.png][]

运行成功

5、访问页面UI

访问localhost：8081

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNzcxNTY3_size_16_color_FFFFFF_t_70 1][]

主页的32就是我们配置的可用的Task Slots, 目前还剩32个槽位，右边是正在运行的任务，当前没有

左侧从上往下分别是 正在运行任务、已取消任务、任务管理器、Job管理、提交新任务

6、利用web Ui提交新任务

我们点击左侧最下边Submit New Job,点击右上角Add New。

Add New之前，我们先将之前几篇中我们写好的Flink程序打包

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNzcxNTY3_size_16_color_FFFFFF_t_70 2][]

利用maven双击 compile编译，再双击package打包，我们就发现左侧的jar包。

继续，AddNew选择我们打包好的jar包

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNzcxNTY3_size_16_color_FFFFFF_t_70 3][]

1的位置是我们的入口Class，我们可以复制引用

![20210324102937973.png][]

2是这个任务的最大调度，如果程序里边配置了，就以程序为真，不然就以此处为真

3是参数 我们的参数是 --host xxx --port xxx

下方左侧 Show Plan点击进去可以看到任务的执行流程以及每个步骤的调度数

右侧Submit提交，我们可以看到任务执行情况

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNzcxNTY3_size_16_color_FFFFFF_t_70 4][]

7、**通过命令行提交任务**

./bin/flink run -c WorldCount -p 2 ./xxx.jar --host localhost --port 7777

利用flink命令进行操作

\-c 是指定入口类

\-p 是任务调度

然后指定jar包位置 后边--是参数配置

**取消任务**

./bin/flink list 查看任务列表以及任务id

./bin/flink cancel id 取消任务

./bin/flink list -a 查看被取消的任务

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNzcxNTY3_size_16_color_FFFFFF_t_70]: /images/20221022/496c5363d0aa4f2ca4ec2a5db616201f.png
[20210324101645382.png]: /images/20221022/687d810ac2fe4b539b892bbbb35bc669.png
[20210324101911996.png]: /images/20221022/faef7d62fb9d4839b11e663c7fd70ea4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNzcxNTY3_size_16_color_FFFFFF_t_70 1]: /images/20221022/1faefe53b9764613a49ff20aa3bc667f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNzcxNTY3_size_16_color_FFFFFF_t_70 2]: /images/20221022/d31bdbaf58d94ab3b0963bddd0fa2a09.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNzcxNTY3_size_16_color_FFFFFF_t_70 3]: /images/20221022/e02124b9924a4b1b89dfb473bb758894.png
[20210324102937973.png]: /images/20221022/76eedd889e214e8c811375f424098d4e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNzcxNTY3_size_16_color_FFFFFF_t_70 4]: /images/20221022/fb4159e745d34161bd3d5bba7835ed56.png