Flink状态管理

Flink最区别于其他流式计算引擎的,其实就是状态管理。 1.什么是状态 在数据处理任务中,经常要对数据进行统计,如Sum、Count、Min、

Flink作业并行度配置

Flink程序的并行执行 Flink程序的执行是并发和分布式的,在执行期间,一个流(stream)会有一个或者多个流分片(stream part

Flink作业管理

Flink集群架构 Flink运行时包含两类进程:JobManager和TaskManager。其中JobManager负责协调分布式计算,包

Apache Flink社区

Apache Flink作为对当前国内炙手可热的流式计算框架,在阿里的积极布道、运作下,有望成为大数据实时计算的实际标准。 Flink社区 Flink mailing list Flink