标签：Flink
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主要就是定义了上面两方面的……
Flink NetworkBuffer 动态申请
Flink中NetworkBuffer相关配置对用户来说比较复杂，用户很难去配置一个合理的值，使用过程中主要以下两方面问题：NetworkBuffer不够导致的作业启动失败，大部分作业NetworkBuffer浪……