02 请描述 Spark 程序的提交计算流程,并解释宽窄依赖的概念以及为什么以宽依赖为边界划分 Stage。考察对 Spark 核心机制的理解,包括作业提交、依赖划分和 Stage 划分原理。 查看学习思路
04 请解释 Kafka 的架构,并说明 Flink 中时间窗口和 Watermark 的概念,以及 Watermark 如何触发窗口计算?在多并行度下 Watermark 如何触发?考察对 Kafka 架构和 Flink 时间窗口、Watermark 机制的理解,以及多并行度下的处理逻辑。 查看学习思路