Tag: stream-processing

All the articles with the tag "stream-processing".

• Flink 深挖 · 部署模式与 Flink on K8s

  25 Jul, 2025
  • #flink
  • #stream-processing
  • #deployment
  • #kubernetes
  • #adtech

  Flink 生产部署收尾：Session / Per-Job / Application 三种模式怎么选、为何生产选 Application、Flink on Kubernetes 的 Native 与 Operator 两条路线、JobManager 高可用与 checkpoint 存储、资源与内存模型、stop-with-savepoint 优雅升级。

• Flink 深挖 · 反压定位与性能调优

  22 Jul, 2025
  • #flink
  • #stream-processing
  • #real-time
  • #performance
  • #tuning

  Flink 反压：credit-based 网络流控、Web UI 与 busyTime 定位反压起点、数据倾斜的两阶段聚合与加盐打散、AsyncFunction 异步维表 join，及并行度/RocksDB/unaligned checkpoint 调优。

• Flink 深挖 · 状态管理与 Checkpoint 容错

  19 Jul, 2025
  • #flink
  • #stream-processing
  • #real-time
  • #fault-tolerance
  • #system-design

  Flink 有状态计算与容错：Keyed/Operator State 原语、HashMap/RocksDB 后端、Chandy-Lamport Checkpoint barrier 快照、aligned/unaligned 取舍与 Savepoint。

• 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 事务两阶段提交。