关于后端:面试题百日百刷flink篇三

28次阅读

共计 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 上, 理解更多请点我头像或到我的主页去取得,谢谢 **

正文完
 0