Flink核心概念与应用

Flink概述

  • 什么是Flink?
  • Flink的特点与优势

Flink编程模型

  • 批处理
  • 流处理

重要概念

  • Task与Operator Chains
  • 数据流图
  • 并行度

Task划分

  • TaskManager
  • JobManager

共享资源槽

  • Slot的概念
  • 资源分配与隔离

Flink的时间

  • 事件时间
  • 处理时间
  • 摄入时间

Flink的Window

  • 时间窗口
  • 计数窗口
  • 会话窗口

Flink的WaterMark

  • WaterMark机制
  • 迟到数据处理

重启策略

  • 固定延迟重启
  • 失败率重启
  • 无重启