淘天数开实习一眼kpi

1. 自我介绍。2. 深挖项目3. 在项目中，你具体负责和完成了哪些工作？4. 你们是如何划分DWD、DWM、ADS这些数据分层的？5. 在项目过程中遇到了哪些难点？6. 描述一下二次分区，以及它为什么能解决数据膨胀的问题？7. 你如何理解Flink中的“状态”？用了哪几种状态后端？8. 启动Flink任务后，状态是缓存在哪里的？9. 你刚说Hbase作为状态后端，实践过吗？ 我答只停留在理论，没实践过10. 能否描述一下Spark的执行原理和提交过程？11. 在做离线处理时，有遇到过数据倾斜的问题吗？是如何解决的？12. 你了解Flink的回撤流吗？你的使用场景下，会生成几条数据?  我答了1条，面试官告诉我是2条手撕： 三数之和 + 前缀积反问：1. 业务是什么2. 工作强度大不大3. 对正职能力和性格素质方面的要求1h7min，2/3的时间都在挖项目，最后两道算法，不知道为啥没有sql

问获取电池电量信息后，spark怎么计算平均耗电（？）速率上来第一个问题，我没重视随便答了一下用DataFrame存储，然后用SparkSQL处理，计算差值什么的（感觉应该是不太满意）面试官给的场景题，描述的非常模糊，大致意思就是收集到每10分钟的电车电池剩余电量的数据，问我用Spark怎么算电池消耗速率求大佬解析，主要是不清楚面试官想考的是什么，挂的也是云里雾里9.10 一更：现在想想， 第一题可能是： 先切分分区，然后看有无数据倾斜，如果有加盐打散 然后开始预聚合（大概） 然后就考虑按什么聚合，什么业务需求 估计还要sort merge join，归并排序+溢写9.12 二更：现在想想可能...

1.面试官自我介绍2.自我介绍（跳过学历背景，直接介绍项目）3.聊实习项目4.算法 最大子数组和+乘积最大子数组 两个hot100 medium5.sql 窗口函数秒了6.数据倾斜怎么排查，如何解决7.spark内存模型，每一部分的作用，如何调参8.反问（聊天）50min面的北京岗位。面试官挺随和的，整场面试感觉像聊天——9.15更新 约二面

面试官人很好 很温和 全程没有打断 还会很耐心的讲业务和轮岗流程等等 非常舒服 问题还是挺常规的，问简历，职业规划..专业知识没有问很多  三面继续接好面试官 我大接特接