[大数据面试]-- 5.Flink 题目_flink选择题

========= 基础 =========

1、Flink 的 抽象层次有几种

Stateful stream processing

Core API

Table

SQL

 

2、Window 类型

(1)TimeWindow

Tumbling Window(滚动窗口)

Sliding Window(滑动窗口)

Session Window(会话窗口)

Global Window(全局窗口)

(2)countWindow

(3)自定义window

 

3、Time 类型

事件时间、注入时间和Processing Time

 

4、Checkpoint的理解

• 轻量级容错机制(全局异步，局部同步)
• 保证exactly-once 语义
• 用于内部失败的恢复
• 基本原理：通过往source 注入barrier，barrier作为checkpoint的标志

 

5、Savepoint

• 流处理过程中的状态历史版本
• 具有可以replay的功能
• 外部恢复（应用重启和升级）
• 两种方式触发：Cancel with savepoint，手动主动触发

$s bin/flink savepoint :jobId [:targetDirectory]

$ bin/flink cancel -s [:targetDirectory] :jobId

 

6、Flink runtime archi