专高二第7单元
欢迎参加本次Flink技术知识考试，请认真作答以下题目。
1. Flink SQL中，以下哪种数据类型用于表示可变长度字符串
VARCHAR
CHAR
String
TEXT
2. Flink的Async I/O主要用于解决什么问题
外部系统访问的延迟问题，提高吞吐量
数据进入Flink的时间
内存溢出问题
数据倾斜问题
3. 以下哪种情况不会触发Flink的重启策略
Task异常
JobManager故障
Checkpoint失败
手动取消作业
4. 在Flink的DataStream API中，以下哪个方法用于设置并行度
setParallel()
parallelism()
setParallelism()
setDegreeOfParallelism()
5. Flink的Checkpoint间隔设置需要考虑的因素不包括
业务延迟要求
状态大小
网络带宽
数据倾斜程度
6. 以下哪个不是Flink窗口的默认触发器
EventTimeTrigger
ProcessingTimeTrigger
CountTrigger
ManualTrigger
7. Flink的TaskManager中，Slot的主要作用是
存储数据
资源隔离和分配
网络通信
状态管理
8. Flink的Managed Memory主要用于
用户代码执行
批处理排序和哈希操作
网络缓冲
JVM元数据
9. 以下哪种情况会导致 Flink 的 Checkpoint 失败，但作业不会自动重启
同时满足 checkpoint.max-concurrent-checkpoints=1 且新 Checkpoint 触发时上一个仍在进行
用户代码在 snapshotState() 方法中抛出异常
某个 Task 的 Checkpoint 快照写入 HDFS 时网络中断
Checkpoint 超时（超过 checkpoint.timeout 配置）
10. Flink代码片段.countWindow（5）表示为
滚动窗口，5 个相同 key 的元素计算一次。
滑动窗口，当相同 key 的元素个数达到 5个时，触发窗口计算，计算的窗口范围为 5
滚动窗口，计算的 window 范围是 5s 内的所有元素。
滑动窗口，窗口每 5s 就计算一次，每一次计算的 window 范围是 5s 内的所有元素。
11. Flink 提供了哪三种状态存储方式？
MemoryStateBackend
FsStateBackend
RocksDBStateBackend
RedisStateBackend
12. Flink重启策略的配置方式包括
配置文件flink-conf.yaml
代码中设置RestartStrategies
命令行参数
Web UI设置
13. 对于 TimeWindow，可以根据窗口实现原理的不同分成三类，即
滚动窗口(Tumbling Window)
滑动窗口(Sliding Window)
会话窗口(Session Window)
全局窗口(Global Window)
14. 以下哪些是Flink SQL支持的DDL语句
CREATE TABLE
CREATE VIEW
DROP TABLE
ALTER TABLE
15. 在 Flink 的流式处理中，会涉及到时间的不同概念，包括
Event Time
Processing Time
Ingestion Time
System Time
16. ProcessFunction 是底层 API，提供 Context 访问时间戳、Watermark，并通过 TimerService 注册事件时间/处理时间定时器
对
错
17. Flink的State TTL StateTtlConfig.UpdateType包括OnCreateAndWrite（创建和写入时更新）和 OnReadAndWrite（读写都更新）
对
错
18. 双流数据按 Key 关联，且需要处理一侧数据到达而另一侧未到达的等待逻辑可以使用CoProcessFunction
对
错
19. CoProcessFunction 提供 processElement1 和 processElement2，可自定义状态缓存、超时处理、复杂匹配逻辑（如订单超 30 分钟未支付告警）
对
错
20. Per-Job 模式客户端需保持连接监控作业，Application 模式客户端提交后即可退出
对
错
关闭
更多问卷
复制此问卷