订阅更新

Flink 面试题61 道

实时计算：状态、Checkpoint、Watermark、反压、Flink SQL

全部 FlinkSparkKafka项目与面试表达Hadoop / Hive / HBaseAI 与大模型OLAP 与数据湖数仓建模SQL 与数据库数据应用：画像 / 指标 / 报表数据开发与治理Java 与 JVMPythonLinux 与运维分布式与综合
按题号 最新在前
  1. 003 Flink 任务出现反压，你怎么排查？
  2. 005 Flink Checkpoint 经常失败，你怎么排查？
  3. 007 Flink 的 Exactly-Once 是怎么实现的？
  4. 014 Flink Watermark 和迟到数据怎么处理？
  5. 016 Flink State 太大，你怎么优化？
  6. 020 Flink 维表 Join 怎么设计？
  7. 023 Flink Checkpoint 和 Savepoint 有什么区别？
  8. 028 Flink 窗口怎么选？滚动、滑动、会话有什么区别？
  9. 031 Flink 并行度怎么设置？
  10. 034 Flink Async IO 怎么用
  11. 039 Flink Keyed State 和 Operator State 有什么区别？
  12. 044 Flink Window Join 和 Interval Join 怎么选？
  13. 049 Flink Broadcast State 怎么用？有哪些注意点？
  14. 054 Flink Side Output 什么时候用？
  15. 059 Flink Timer 什么时候用？有哪些坑？
  16. 064 Flink Barrier 对齐和非对齐 Checkpoint 有什么区别？
  17. 109 Flink CDC 遇到 Schema Evolution 怎么处理？
  18. 127 Flink Operator Chain 和 Slot Sharing 怎么理解？
  19. 128 Flink 任务升级时，State 如何兼容？
  20. 149 Flink State Backend 怎么选？
  21. 159 Flink CEP 怎么做复杂事件检测？
  22. 168 Flink ProcessFunction 能做什么？
  23. 169 Flink SQL Changelog 是什么？
  24. 178 Flink Temporal Join 如何关联版本化维表？
  25. 191 Flink Restart Strategy 和 Failover Strategy 有什么区别？
  26. 192 Flink State TTL 怎么配置？为什么数据不会立即删除？
  27. 207 Flink 增量 Checkpoint 是怎么工作的？
  28. 216 Flink 数据倾斜怎么排查和治理？
  29. 233 Flink Mailbox 模型怎么工作？为什么阻塞调用会拖慢整个 Task？
  30. 234 Flink SQL MiniBatch 和 Local-Global 聚合怎么优化吞吐？
  31. 246 Flink keyBy、rebalance 和 rescale 有什么区别？
  32. 256 Flink 空闲分区为什么会卡住 Watermark？withIdleness 怎么用？
  33. 266 Flink Checkpoint 太慢，怎么区分对齐慢和快照慢？
  34. 276 Flink 有状态任务怎么扩容？并行度和最大并行度有什么区别？
  35. 287 Flink Watermark 已经推进，窗口为什么还没有输出？
  36. 296 Flink Buffer Debloating 是什么？把网络缓冲调大就能消除反压吗？
  37. 306 Flink Timer 太多怎么优化？合并定时器会不会提前触发？
  38. 316 Flink Async IO 有 Exactly-once，调用外部接口就不会重复吗？
  39. 326 Flink Watermark Alignment 是什么？为什么要主动暂停较快的数据源？
  40. 339 Flink 停任务时 cancel、stop 和 drain 怎么选？
  41. 347 Flink SQL 声明 PRIMARY KEY 就会自动去重吗？NOT ENFORCED 是什么意思？
  42. 05-01 Flink作业跑着跑着突然重启了——Checkpoint到底怎么工作的？
  43. 05-02 数据延迟了5分钟才到——Watermark和Event Time怎么处理乱序数据？
  44. 05-03 实时统计每分钟的PV——Flink的窗口类型怎么选？
  45. 05-04 上游Kafka有数据倾斜，某个算子卡住了——Flink数据倾斜怎么解决？
  46. 05-05 Flink作业反压了，下游处理不过来——反压排查和解决思路
  47. 05-06 Flink作业重启后状态丢了——State怎么管理和恢复？
  48. 05-07 要保证每条数据恰好处理一次——Flink的Exactly-Once怎么实现的？
  49. 05-08 Flink SQL和DataStream API该用哪个？什么场景必须用DataStream？
  50. 05-09 两条流要关联——Flink的双流Join怎么做？
  51. 05-11 Flink作业OOM了——内存模型和调优思路
  52. 05-12 Flink和Spark Streaming到底选哪个？
  53. 05-13 TaskManager的Slot数设多少合适？并行度怎么定？
  54. 05-14 从Savepoint恢复后数据重复了——Savepoint和Checkpoint有什么区别？
  55. 05-16 实时数仓分层怎么做？Flink+Kafka+Doris的架构设计
  56. 05-17 Flink CDC直接读MySQL Binlog——替代Canal的新方案
  57. 05-18 Flink作业上线后指标不对——怎么做实时数据质量监控？
  58. 05-19 Flink SQL的窗口TVF和时间属性——新语法比旧语法好在哪？
  59. 05-20 请描述一个你用Flink做过的项目
  60. 16-06 Flink实时作业背压报警，罪魁祸首是数据倾斜——怎么排查和解决？
  61. 16-18 Kafka→Flink→Doris 整条实时链路，哪个环节倾斜最难搞？端到端排查思路