1.以下几种方式，哪个将 ts 列正确声明成了 event-time attribute ?
A. ts TIMESTAMP(3)
B. ts AS PROCTIME()
C. ts TIMESTAMP(3), WATERMARK FOR ts AS ts - INTERVAL '3' SECOND
D. ts TIMESTAMP(6), WATERMARK FOR ts AS ts - INTERVAL '3' SECOND
正确答案：C
2.Flink Master节点中，与作业为一对一关系的组件有：
A. Dispatcher
B. JobMaster
C. ResourceManager
D. Rest Server
正确答案：B
3.目前实时计算 Flink 半托管形态可以运行在哪些调度系统上？
A. Mesos 和 Yarn
B. Mesos 和 K8S
C. K8S 和 Yarn
正确答案： C
4.以下哪个不属于流式处理的特点？
A. 带时间属性的事件
B. 有界的事件流
C. 主动触发的处理
正确答案： C
5.关于Blink独享集群，哪些说法是正确的？
A. 只支持Blink SQL作业类型
B. 只支持Datastream作业类型
C. 同时支持Blink SQL和Datastream作业类型
正确答案： B
6.以下哪项不是 Flink Serverless（Flink 全托管） 的核心优点？
A. 与用户 VPC 打通
B. 用户可登机运维
C. 高安全隔离
正确答案： B
7.以下哪个场景不属于Flink的技术场景？
A. Stream Analytics
B. Event-Driven Application
C. Stream ML
正确答案：C
8.截止到Flink-1.11，以下StateBackend在访问状态数据时，需要通过JNI的访问的是
A. MemoryStateBackend
B. FsStateBackend
C. RocksDBStateBackend
D. SpillableStateBackend (FLINK-12692)
相关知识点： 该StateBackend依赖于RocksDB，而RocksDB作为native库访问数据需要与java之间通过JNI通信
正确答案： C
9.下面哪个不属于Flink全托管的运维界面？
A. Bayes
B. VVP
C. Flink Web UI
正确答案： A
10.Slot的申请发生在任务生命周期的哪一阶段？
A. CREATED
B. SCHEDULED
C. DEPLOYING
D. RUNNING
正确答案： B
11.开通实时计算Flink版产品时，如下哪些说法是错误的？
A. 必须注册、登陆阿里云账号并进行对应的角色授权操作
B. 可以创建与实时计算Flink版产品集群不同region的OSS和VPC
C. 必须创建与实时计算Flink版产品集群相同region的OSS和VPC
正确答案： B
12.开通Flink 全托管时，下面哪个步骤不是必须的？
A. 购买订单
B. 创建集群
C. 创建项目空间（自动）
正确答案： B
13.目前实时计算 Flink 的技术品牌是？
A. Bayes
B. Realtime Compute
C. Ververica
正确答案： C
14.从使用者角度来看，下面实时计算哪个产品形态与其他产品形态差异最大？
A. Flink 全托管
B. Flink 半托管
C. Blink 独享集群
正确答案：C
15.以下哪个不是本次训练营所讲述的行业场景？
A. 金融行业
B. IOT行业
C. 电商行业
正确答案：B
16.PyFlink中的依赖管理支持哪些类型的依赖
A. 普通Python文件
B. Python三方库
C. Jar包
D. 存档文件，比如zip包
E. 指定Python解释器路径
正确答案：ABCDE
17.以下 Flink 原生支持的 connector，哪些提供了维表关联的功能？
A. Hive
B. JDBC
C. Elasticsearch
D. HBase
正确答案： A B D
18.Python UDF支持在哪些场景使用：
A. SQL作业
B. Java Table API作业
C. Python Table API作业
D. Java DataStream作业
正确答案： A B C
19.Catalog在Flink SQL中的作用包括：
A. 管理用户注册的UDF
B. 提供持久化元数据的能力
C. 实际表数据的读写
D. 提供TableFactory来创建source和sink
正确答案： A B D
20.截止到Flink-1.11，以下关于StateBackend创建的KeyedStateBackend在执行checkpoint时，描述正确的是：
A. MemoryStateBackend 支持异步checkpoint
B. MemoryStateBackend 支持本地快速恢复（local recovery）
C. FsStateBackend 支持增量checkpoint
D. RocksDBStateBackend 既支持异步checkpoint，也支持增量checkpoint
相关知识点： 目前 state.backend.local-recovery不支持MemoryStateBackend，所以B不正确；state.backend.incremental 仅支持RocksDBStateBackend，所以C不正确。
正确答案： A D
21.以下属于Flink SQL中原生支持的connector的是：
A. FileSystem
B. JSON
C. JDBC
D. Avro
正确答案：AC
22.Flink SQL 原生支持的 window 功能有哪些？
A. Tumbling time window
B. Tumbling count window
C. Sliding time window
D. Session time window
正确答案：ACD
23.以下说法正确的是：
A. Flink SQL的savepoint能保证跨版本的兼容性
B. Flink SQL本身不拥有和管理数据
C. HiveCatalog可以存储非Hive表的元数据
D. Elasticsearch table source只支持batch模式
正确答案： B C
24.以下 Flink 原生支持的 connector，哪些能用来接收 SELECT user, count(*) FROM T GROUP BY user 的结果？
A. Kafka
B. JDBC
C. Filesystem
D. Elasticsearch
正确答案： B D
