Tag: flink

All the articles with the tag "flink".

• Flink 深挖 · DataStream API：ProcessFunction、状态、Timer 与 Side Output

  18 Jul, 2025
  • #flink
  • #stream-processing
  • #real-time
  • #datastream
  • #adtech

  从 Flink SQL 下沉到 DataStream API：什么时候必须用底层 API、DataStream 心智与 SQL 对照、KeyedProcessFunction 的状态/TimerService/OutputTag 三大件，并用累计告警、支付超时、迟到分流、接 Kafka 聚合四个可跑实战串起来。

• Flink 深挖 · 端到端 Exactly-Once 与两阶段提交

  13 Jul, 2025
  • #flink
  • #stream-processing
  • #real-time
  • #exactly-once
  • #kafka

  深挖 Flink 端到端 Exactly-Once：厘清 at-most/at-least/exactly-once 含义、内部靠 checkpoint 一致性快照实现、端到端为何需要可重放 source 与事务 sink，及 Kafka 事务两阶段提交。

• Flink 深挖 · 时间语义、窗口与 Watermark

  11 Jul, 2025
  • #flink
  • #stream-processing
  • #real-time
  • #event-time
  • #system-design

  Flink 时间语义与乱序：processing/ingestion/event time 取舍、Watermark 与多输入取 min、Tumbling/Sliding/Session 窗口、allowedLateness 与侧输出兜底、增量/全量聚合。

• Flink 深挖（开篇）· 流处理模型与运行时架构

  6 Jul, 2025
  • #flink
  • #stream-processing
  • #real-time
  • #adtech
  • #system-design

  Flink 深挖开篇：为何广告实时链路选 Flink 而非微批、DataStream 流处理心智、JobManager/TaskManager/Slot 运行时、StreamGraph→JobGraph→ExecutionGraph 转换与算子链、部署模式。