莫方教程网

专业程序员编程教程与实战案例分享

Flink概述

1.Flink用于实时流的处理,具有高吞吐、低延迟、高性能的特性。Apache Flink是一个框架和分布式处理引擎,用于对无界和有界数据流进行有状态计算。Flink设计为在所有常见的集群环境中运行,以内存速度和任何规模执行计算。Flink可以以任务规模并行执行任务;

2.Flink的架构:Client提交任务给JobManager,JobManager分发任务给TaskManager;TaskManger会心跳的汇报任务状态;TaskManager 之间是流;TaskManager内部和taskManager可以进行数据传递;

3.Flink底层就是流,如果需要批处理,当成有界流即可;而spark streaming为微批处理,哪怕当成一条为一个微批,底层架构不一样,耗时还是有区别。

常用命令:

1.命令启动flink任务

./flink run -c org.example.flink.StreamWordCount -p 3 /mnt/f/work/learn_project/SpringCloudLearning/flink-demo/target/flink-demo.jar --host localhost --port 7777

2.查看flink执行的任务清单

./flink list

3.停止则为 ./flink cancel
e393f878ad512757c375a5da30209625

控制面板
您好,欢迎到访网站!
  查看权限
网站分类
最新留言

    滇ICP备2024046894号-1