Flink面试常见的25个问题（无答案）

1. flink和spark streaming的优缺比较
2. Flink on Yarn任务提交流程
3. Flink Sql的执行过程
4. Flink所使用的版本
5. Flink 内存模型
6. Flink Watermark机制
7. Flink CheckPoint机制？kafka exactly-once的两阶段提？
8. Flink 状态存储backend类型？RocksDBStateBendback的使用场景，优缺点？Flink1.14版本状态存储类型的变化  ？
9. FlinkSql 无界流聚合中mini-batch的使用优缺点
10. Flink operater chain算子链的机制及优点
11. Flink异常后重启策略（固定间隔，失败频率，不重启）
12. Flink设置并行度的几种方式（配置文件，客户端，操作算子，执行环境）
13. Flink 反压问题产生原因及如何定位排查
14. Flink checkpoint失败原因及如何定位排查
15. Flink数据倾斜有什么影响？如何处理数据倾斜？
16. Flink数据流向（source数据源，sink数据库等，为啥要选择这个sink的数据库，对这个数据库有多少了解）
17. Flink 物理执行流程（StreamGraph -> JobGraph -> ExecutionGraph -> 物理执行图）
18. Flink 1.14中的新增功能点
19. Flink中常用的算子有哪些，shuffer类的算子有哪些？
20. 是否使用过广播变量，使用过？什么场景
21. Flink state的类型（keyState，operaterState）,key state有哪些？
22. flink join类型有哪些？
23. flink 测输出流作用有哪些？
24. flink slot和parallelism区别？ slot是指taskmanager的并发执行能力，parallelism是指taskmanager实际使用的并发能力
25. flink cdc原理
26. 日常学习有哪些途径？

欢迎留言区补充更多可能问到的问题，上述问题如找不到答案也可在评论区留言