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