1. 面试官：如何使用Flink批处理API编写一个自定义的MapFunction？

2. 面试官：Flink批处理API中如何处理异常和错误？

3. 面试官：请解释Flink批处理API中的数据源和数据汇的概念？

4. 面试官：如何在Flink批处理API中实现自定义的Aggregator函数？

5. 面试官：Flink批处理API中的Window操作是如何工作的？请详细解释。

6. 面试官：Flink批处理API中的Checkpoints和Savepoints有什么区别？

7. 面试官：如何在Flink批处理API中处理无界流数据？

8. 面试官：Flink批处理API中的优化技巧和性能调优策略是什么？

9. 面试官：请解释Flink批处理API中的各种Join操作及其适用场景？

10. 面试官：Flink批处理API中的状态处理是如何工作的？请举例说明。