A.NgixB.ConsoleC.ZookeeperD.HAProxy下列选项中可以作为Flink集群HA解决……

单项选择题下列选项中不能作为Flink集群部署方式的是（）

A.Mesos
B.Yarn
C.Kubernetes
D.Dolphin Scheduler

单项选择题下列选项中可以判断作业是否积压的指标是（）

A.单位时间消费消息条数
B.反压采样结果
C.单位时间消费消息体积
D.单条消息的体积

单项选择题下列选项不包含在Flink架构中的是（）

A.JobManager
B.TaskManager
C.Slot
D.Executor

单项选择题Flink架构采用的容错策略是（）

A.Checkpoint
B.WAL
C.RDD
D.依赖上游的容错策略

单项选择题下列哪项不属于Flink基本概念（）

A.DataStream
B.DataSet
C.Table
D.RDD

单项选择题下列哪项参数用于设置executor数目（）

A.spark.executor.num
B.spark.executor.instances
C.spark.executor.count
D.spark.executor.scale

单项选择题下列哪项用于查看Spark on Yarn任务日志（）

A.yarn logs -applicationId < app ID>
B.yarn logs -id < app ID>
C.yarn application -log < app ID>
D.yarn applicationLog < app ID>

单项选择题下列哪个参数用于指定Spark on Yarn的任务队列（）

A.spark.yarn.queue
B.spark.yarn.line
C.spark.yarn.seat
D.spark.yarn.priority

单项选择题以下哪项不属于Spark组件（）

A.Spark SQL
B.Spark Streaming
C.PySpark
D.SparkC

单项选择题RDD的默认Storage Level是（）

A.MEMORY_ONLY
B.MEMORY_AND_DISK
C.MEMORY_ONLY_SER
D.MEMORY_AND_DISK_SER

单项选择题sc是已创建的SparkContext实例，data是已创建的数组，使用data创建RDD的代码是（）

A.sc.fromArray（data）
B.sc.parallelize（data）
C.sc.copyFromArray（data）
D.sc.rdd（data）

单项选择题下列Spark算子中不会产生shuffle的算子是（）

A.map
B.distinct
C.groupByKey
D.reduceByKey

单项选择题Spark用于描述RDD依赖关系的模型是（）

A.DAG
B.DBG
C.DCG
D.DDG

单项选择题以下哪项不属于Spark SQL的关联类型（）

A.BroadcastJoin
B.ShuffledHashJoin
C.SortMergeJoin
D.StreamHashJoin

单项选择题下列哪项可作为spark.sql.orc.impl参数的值（）

A.arrow
B.orc1.5
C.native
D.orc1.6