标签:Flink StateBackend

Flink Task Deploy & Task Failover
整体介绍下Flink中TaskDeploy&Recovery的整体流程
Flink StateBackend:State In Join
关于FlinkState在IntervalJoin中的应用。
Flink StateBackend:Checkpoint Recover
FlinkStateRecovery实现细节主要在StreamTaskStateInitializerImpl.streamOperatorStateContext()中。
Flink StateBackend:Checkpoint Snapshot
Snapshot由ExecutionGraph.CheckpointCoordinator来触发,StreamInputProcessor中做完Barrier对齐之后,会调用Operator的snapshotState来做Checkpoint。
Flink StateBackend:概述
FlinkState主要涉及到两方面:作业运行时State如何维护(内存VS磁盘,数据如何组织),Checkpoint快照/恢复时,如何快照/恢复State数据。而StateBackend主要就是定义了上面两方面的……