1. 面试官：请解释Flink流式处理中的数据分发策略，并举例说明其在不同场景下的应用。

2. 面试官：谈谈Flink流式处理中的水位线（Watermark）概念及其在事件时间处理中的作用。

3. 面试官：详细解释Flink流式处理中的网络通信模型及优化方式。

4. 面试官：探讨Flink流式处理中的数据本地性和任务调度策略，以及如何提高作业的并行度。

5. 面试官：解释Flink中的状态管理以及在流式处理中的作用，讨论流的并行化时状态一致性的挑战和解决方案。

6. 面试官：详细介绍Flink流式处理中的作业容错机制，包括检查点（Checkpoint）和保存点（Savepoint）的原理和应用。

7. 面试官：谈谈Flink流式处理中的异步IO模型和其在实时流处理中的优势与挑战。

8. 面试官：探讨Flink流式处理中的连接器（Connector）与外部系统的集成，以及在实际应用中如何保证端到端的 Exactly-Once 语义。

9. 面试官：详细解释Flink流式处理中的事件时间（Event Time）处理与处理时间（Processing Time）处理的区别，以及在不同场景下的选择。

10. 面试官：请解释Flink流式处理中的窗口（Window）概念及其在实时计算中的应用，讨论滚动窗口、滑动窗口和会话窗口的特点及适用场景。