Tag: flink

All the articles with the tag "flink".

• Flink 深挖 · DataStream API 与有状态处理

  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 与 effectively-once 的含义、内部靠 checkpoint 一致性快照回滚重放、端到端需要可重放 source 与幂等或事务 sink，及 Kafka 事务两阶段提交与 transaction.timeout.ms 的坑。

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

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

  Flink 时间语义与乱序处理：processing/ingestion/event time 取舍、Watermark 生成与多输入取 min、withIdleness 排除空闲分区、Tumbling/Sliding/Session 窗口、allowedLateness 与侧输出兜底、增量与全量聚合，落到实时 CTR 与归因 join。

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

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

  Flink 深挖开篇：为何广告实时链路选 Flink 而非微批、流批一体与 DataStream 心智、JobManager/TaskManager/Slot 运行时、StreamGraph→JobGraph→ExecutionGraph 三次图变换、算子链与 Slot 共享、四种分区策略、部署模式与作业提交全流程。