1. 面试官：如何解释Apache Flink的状态一致性模型？

2. 面试官：利用实时流处理举例说明Apache Flink的事件时间处理方式？

3. 面试官：什么是Apache Flink的Exactly-Once语义？如何实现的？

4. 面试官：为什么在Apache Flink中使用窗口操作？有哪些窗口类型可以使用？

5. 面试官：Apache Flink中的水位线是什么？如何使用水位线来处理乱序事件？

6. 面试官：详细解释Apache Flink的作业状态保存和恢复机制？

7. 面试官：如何在Apache Flink中实现流与流之间的连接和合并？

8. 面试官：Apache Flink中的异步IO是如何实现的？有哪些注意事项？

9. 面试官：Apache Flink中的时间语义（Time Semantics）是什么？和事件时间（Event Time）有何区别？

10. 面试官：详细讲解Apache Flink的作业图（JobGraph）和任务图（TaskGraph）的概念和关系？