flink学习

it2026-09-25  17

FlinK的主要特点

事件驱动

基于流的世界观

      有界流 与无界流

分层API

ProcessFunction(events,state,time)  => datastreamApi(strems/windows) => SQL(dynamic tables)

其他特点:

 高可用

Flink运行时的组件

 作业管理器 jobManger :控制一个应用程序执行的主进程,也就是说,每个应用程序都会被一个不同的jobManager所控制

 任务管理器 taskManger

资源管理器ResourceManger

分发器Dispacher

 

standline集群

启动flink

./bin/start-cluster.sh

关闭flink

./bin/stop-cluster.sh

flink 提交命令:

./bin/flink run -c 类名 -p 并行度  jar包位置  参数 

查看正在运行的flink:

./bin/flink list 

查看所有的flink任务

./bin/flink list -a 

关闭flink任务

./bin/flink cancle  jobid

 

 

 

最新回复(0)