面试题频道-k6k4.com

分类

一个创业中的苦逼程序员

hr面 Java C/C++ Python 数据库操作系统网络
AI/算法大数据 Spark Hive Hbase Kafka Zookeeper

1 、 Flink 中的分布式快照机制是如何实现的？

2 、 Flink 计算资源的调度是如何实现的？

3 、 TaskManager在集群中扮演了什么角色？

4 、 Flink所谓"三层图"结构是哪几个"图"？

5 、 Flink Job的提交流程

6 、消费kafka数据的时候，如何处理脏数据？

7 、说说Flink1.9的新特性？

8 、 Flink什么情况下才会把Operator chain在一起形成算子链？

9 、 Operator Chains（算子链）这个概念你了解吗？

10 、 Flink的反压和Strom有哪些不同？

11 、 Flink是如何处理反压的？

12 、 Flink任务延迟高，想解决这个问题，你会如何入手？

13 、 Flink中在使用聚合函数 GroupBy、Distinct、KeyBy 等函数时出现数据热点如何解决？

14 、 Flink中的Window出现了数据倾斜，你有什么解决办法？

15 、说说 Flink的序列化如何做的?

16 、说说 Flink的内存管理是如何做的?

17 、 Flink是如何保证Exactly-once语义的？

18 、 Flink 分布式快照的原理是什么？

持续创建分布式数据流及其状态的一致快照。

在input source端插入barrier，控制barrier的同步来实现snapshot的备份和exactly-once语义。

19 、 Flink是如何做容错的？

20 、 Flink是如何做到高效的数据交换的？

内推：

数据研发工程师 / 个推

Copyright © 2014-2024 k6k4.com 版权所有

浙公网安备 33010602006230号

浙ICP备14015892号

隐藏