1. 面试官：使用 Flink 实现会话窗口的逻辑是什么？如何在会话窗口中管理状态？

2. 面试官：请解释 Flink 中的滑动窗口和滚动窗口的区别，并举例说明它们在实时数据处理中的应用场景。

3. 面试官：讲解 Flink 中时间窗口的处理机制以及如何处理乱序数据问题。

4. 面试官：如何在 Flink 中实现增量窗口聚合操作？请提供示例代码。

5. 面试官：请说明 Flink 中的窗口合并策略，以及在实际应用中如何选择合适的窗口合并策略。

6. 面试官：讲解 Flink 中的快照机制以及如何实现容错性，在容错恢复时会发生什么？

7. 面试官：如何处理 Flink 中的状态管理和状态后端？请解释不同的状态后端类型以及它们的优缺点。

8. 面试官：请介绍 Flink 的保存点机制，以及如何实现保存点的创建、回滚和作业重启。

9. 面试官：使用 Flink 实现事件时间处理的原理是什么？如何解决数据延迟和乱序问题？

10. 面试官：在 Flink 中使用 RocksDB 状态后端和默认内存状态后端有哪些区别？为什么选择 RocksDB 状态后端？