flink scala shell命令行使用示例

太过爱你忘了你带给我的痛 2023-10-06 12:21 0阅读 0赞

## scala shell命令行 ##

用于测试flink集群健康程度。

start-scala-shell.sh remote node01 8081

![在这里插入图片描述][20200704162410368.png]  
启动`flink-scala-shell`：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3NzIzMDQ0MTk_size_16_color_FFFFFF_t_70]  
批计算和流计算：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3NzIzMDQ0MTk_size_16_color_FFFFFF_t_70 1]  
启动一个流计算：

senv.socketTextStream("node01",8888).flatMap(_.split(" ")).map((_,1)).keyBy(0).sum(1).print()

![在这里插入图片描述][202007041628024.png]  
但此时没有真正启动，需要调用如下命令才能真正启动：

senv.execute("first shell job")

![在这里插入图片描述][20200704163225321.png]  
执行上条命令之前要先开一个socket：  
![在这里插入图片描述][20200704165958346.png]  
此时才能真正启动：  
![在这里插入图片描述][20200704163323581.png]

[20200704162410368.png]: https://img-blog.csdnimg.cn/20200704162410368.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3NzIzMDQ0MTk_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200704162522642.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3NzIzMDQ0MTk=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3NzIzMDQ0MTk_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/202007041627029.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3NzIzMDQ0MTk=,size_16,color_FFFFFF,t_70
[202007041628024.png]: https://img-blog.csdnimg.cn/202007041628024.png
[20200704163225321.png]: https://img-blog.csdnimg.cn/20200704163225321.png
[20200704165958346.png]: https://img-blog.csdnimg.cn/20200704165958346.png
[20200704163323581.png]: https://img-blog.csdnimg.cn/20200704163323581.png