共计 1187 个字符，预计需要花费 3 分钟才能阅读完成。
锁屏面试题百日百刷，每个工作日保持更新面试题。 请看到最初就能获取你想要的, 接下来的是今日的面试题：
1. 说说 Flink 资源管理中 Task Slot 的概念 **
在 Flink 架构角色中咱们提到，TaskManager 是理论负责执行计算的 Worker，TaskManager 是一个 JVM 过程，并会以独立的线程来执行一个 task 或多个 subtask。为了管制一个 TaskManager 能承受多少个 task，Flink 提出了 Task Slot 的概念。简略的说，TaskManager 会将本人节点上治理的资源分为不同的 Slot：固定大小的资源子集。这样就防止了不同 Job 的 Task 相互竞争内存资源，然而须要次要的是，Slot 只会做内存的隔离。没有做 CPU 的隔离。
2. 说说 Flink 的罕用算子？**
Flink 最罕用的罕用算子包含：Map：DataStream → DataStream，输出一个参数产生一个参数，map 的性能是对输出的参数进行转换操作。Filter：过滤掉指定条件的数据。KeyBy：依照指定的 key 进行分组。Reduce：用来进行后果汇总合并。Window：窗口函数，依据某些个性将每个 key 的数据进行分组（例如：在 5s 内达到的数据）
3.Flink 的并行度理解吗？Flink 的并行度设置是怎么的？**
Flink 中的工作被分为多个并行任务来执行，其中每个并行的实例解决一部分数据。这些并行实例的数量被称为并行度。咱们在理论生产环境中能够从四个不同层面设置并行度：
操作算子层面 (Operator Level)
执行环境层面 (Execution Environment Level)
客户端层面 (Client Level)
零碎层面 (System Level)
须要留神的优先级：算子层面 > 环境层面 > 客户端层面 > 零碎层面。
4.Flink 的 Slot 和 parallelism 有什么区别？
slot 是指 taskmanager 的并发执行能力，假如咱们将 taskmanager.numberOfTaskSlots 配置为 3 那么每一个 taskmanager 中调配 3 个 TaskSlot, 3 个 taskmanager 一共有 9 个 TaskSlot。
parallelism 是指 taskmanager 理论应用的并发能力。假如咱们把 parallelism.default 设置为 1，那么 9 个 TaskSlot 只能用 1 个，有 8 个闲暇。
5.Flink 有没有重启策略？说说有哪几种？**
Flink 实现了多种重启策略。
固定提早重启策略（Fixed Delay Restart Strategy）
故障率重启策略（Failure Rate Restart Strategy）
没有重启策略（No Restart Strategy）
Fallback 重启策略（Fallback Restart Strategy）
全部内容在 git 上, 理解更多请点我头像或到我的主页去取得，谢谢 **