下了班同事一起吃饭，同事a：现在90后压力好大啊，都是独生子女，要赡养老人balabala。。。。我内心os：聊这些干鸟，上班压力本来就大了！没想到他是抖机灵还是一时口误，聊着聊着成了90后单身子女。。。单身子女。。。场内场外一下子充满了快活的空气

周五啦，明天上不上班，不上班的小伙伴们本周的活干完了吗？

周五啦，大家活干完了吗

大家好，今天是周一，开始干活了吗

本来以为是问JAVA，因为投递的时候是写着JAVA，结果按简历问了比较多大数据相关。   1、自我简介，项目介绍，问项目细节。   2、Flink的窗口了解哪些，都有什么区别，有哪几种时间？如何定义？watermark需要实现哪个实现类，在何处定义？   3、Flink的CEP了解吗？Checkpoint底层如何实现的？savepoint和checkpoint有什么区别？有哪些实现类可以用来保存中间计算结果？分别有什么区别？   4、Flink有没有遇到过OOM？如何排查？项目的数据规模？问了一些设置参数。   5、spark的stage如何划分，在源码中是怎样判断属于shuffleMapSt...

回村了，过年继续看题，年后再找🤩🤩🤩

1、介绍项目   2、spark的内存模型？sparkonyarn的两种部署方式？区别？   3、flink的任务调度过程？如何处理乱序数据？水印怎么定义怎么实现？最终迟到的数据要怎么处理？   4、jvm那一套、多线程那一套、如何自己设计一个hashmap？   5、问了一堆项目中具体问题和场景   6、100万条数据，内存很小只有1.5MB，要排序怎么办？能使用哪些排序方法？用哪种好？   7、何时发生内存泄漏（内存溢出OOM）？使用过什么工具观察过spark、flink任务执行时的内存运行情况？这两个框架内存溢出异常时分别是什么情况？   8、spark数据倾斜怎么办？使用sample算...

1、介绍项目   2、和算法同学配合的时候，他们用的什么算法对数据特征分析然后去训练？我说知道是din。可以简单介绍一下din算法吗？我：（内心OS：？？？我好像不是算法岗）   3、离线批处理做数据解析的时候，比如A表解析过A1字段，B1字段，B表解析过c1字段，d1字段，现在让你解析新的字段，有没有动态实现的方案可以不修改原先的代码完成功能的实现？   4、接触过哪方面的业务呢？答特征工程。特征工程中有没有接触哪些方面，有没有接触过数据预处理及平滑算法？我。。。解析清洗过哪些字段呢？语义标签、标题、权重、关键词。。。。他们是怎么统计的？我：（内心OS：？？？我没面算法岗呀，难道要回去补课了...

1、线程池（具体参数，拒绝策略，减少线程的机制，具体实现类及对应的阻塞队列，阻塞队列有什么特点，为什么用这个阻塞队列，线程复用的原理）   2、JVM（对象是否可回收的判断条件，怎么判断，回收算法，垃圾回收器的类别及特点，担保机制）   3、JAVA内存模型   4、线程之间的通信方式，通过volatile，synchronized，Lock的实现类那些，结合内存模型去讲。   5、MyBatis、spring、springboot相关（面试题较常见）   6、Linux常用命令   7、redis的数据结构那些，讲了skiplist、ziplist、sds等，结合使用场景说了下   面试时间...

1、介绍项目   2、flink了解吗？自己介绍（。。。）   3、Blink了解吗？   4、HBase的RegionServer宕机以后怎么恢复的？架构？高可用怎么实现的？RowKey规则？    5、MyBatis相关   6、hashMap，多线程那些不赘述了   7、redis数据结构、怎么用的。   问的很简单，给我感觉就是加班很多的项目需要人，看二面情况吧

1、介绍项目及工作经历（略）2、介绍公司的大数据架构（来源、中间件、落地、采用的数据介质）3、scala隐式转换中隐式类和隐式方法有什么区别、隐式转换怎么实现的？4、scala的类继承关系，和Java的异同点。5、scala可变和不可变对象有什么区别？为什么要这样定义？何谓函数式编程？可变集合中，不可变集合.builder和Buffer类集合有什么区别，底层怎么实现的？6、为什么在scala中没有包装类了？7、spring中，IOC的原理？如何解决循环依赖的问题？Bean对象的生命周期？8、java集合类，conCurrentHashMap原理（分段锁，如何实现线程安全，解锁要按顺序吗？）Ha...

一面：   1、介绍项目，公司的大数据架构。   2、kafka怎么保证数据的exactlyonce？   3、offset你们公司如何维护的？为什么不放在mysql？   4、kafka可以保证数据的局部有序，如何保证全局有序的？   5、介绍一下kafka的事务。   6、flink和sparkStreaming的区别？   7、flink批处理和实时处理有什么关系？   8、mapReduce的过程？map端预合并可以做取余操作吗？shuffle过程介绍一下？环形缓冲区溢写的阈值是多少？为什么是这个值？之后用的什么排序？为什么是这个排序？合并和归并有什么区别？   9、十大排序抽几个问空...