- Flink架构
- Flink的窗口了解哪些,都有什么区别,有哪几种?如何定义?
- Flink窗口函数,时间语义相关的问题
- 介绍下Flink的watermark(水位线),watermark需要实现哪个实现类,在何处定义?有什么作用?
- Flink的窗口(实现)机制
- 说下Flink的CEP
- 说一说Flink的Checkpoint机制
- Flink的Checkpoint底层如何实现的?savepoint和checkpoint有什么区别?
- Flink的Checkpoint流程
- Flink Checkpoint的作用
- Flink中Checkpoint超时原因
- Flink的ExactlyOnce语义怎么保证?
- Flink的端到端ExactlyOnce
- Flink的水印(Watermark),有哪几种?
- Flink的时间语义
- Flink相比于其它流式处理框架的优点?
- Flink和Spark的区别?什么情况下使用Flink?有什么优点?
- Flink backPressure反压机制,指标监控你是怎么做的?
- Flink如何保证一致性?
- Flink支持JobMaster的HA啊?原理是怎么样的?
- 如何确定Flink任务的合理并行度?
- Flink任务如何实现端到端一致?
- Flink如何处理背(反)压?
- Flink解决数据延迟的问题
- Flink消费kafka分区的数据时flink件务并行度之间的关系
- 使用flink-client消费kafka数据还是使用flink-connector消费
- 如何动态修改Flink的配置,前提是Flink不能重启
- Flink流批一体解释一下
- 说一下Flink的check和barrier
- 说一下Flink状态机制
- Flink广播流
- Flink实时topN
- 在实习中一般都怎么用Flink
- Savepoint知道是什么吗
- 为什么用Flink不用别的微批考虑过吗
- 解释一下啥叫背压
- Flink分布式快照
- Flink SQL解析过程
- Flink on YARN模式
- Flink如何保证数据不丢失