hadoop3.x Fair Scheduler 公平调度队列内存和yarn.nodemanager.resource.memory-mb的关系

hadoop3.x yarn内存、CPU配置

flink1.12.x Savepoint 案例 - per-job cluster模式

flink1.12.x flink cancel停止flink任务命令

Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout

flink1.12.x Savepoint 案例

setExternalizedCheckpointCleanup(CheckpointConfig.ExternalizedCheckpointCleanup.DELETE_ON_CANCELLATION)setExternalizedCheckpointCleanup(CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION)

flink1.12.x Savepoint（与 checkpoint 的区别）

flink1.12.x barrier对齐和不对齐

flink1.12.x End-to-End 端到端数据一致性：at-most-once、at-least-once