A.MesosB.YarnC.KubernetesD.Dolphin Scheduler
单项选择题下列选项中可以判断作业是否积压的指标是()
A.单位时间消费消息条数B.反压采样结果C.单位时间消费消息体积D.单条消息的体积
单项选择题下列选项不包含在Flink架构中的是()
A.JobManagerB.TaskManagerC.SlotD.Executor
单项选择题Flink架构采用的容错策略是()
A.CheckpointB.WALC.RDDD.依赖上游的容错策略
单项选择题下列哪项不属于Flink基本概念()
A.DataStreamB.DataSetC.TableD.RDD
单项选择题下列哪项参数用于设置executor数目()
A.spark.executor.numB.spark.executor.instancesC.spark.executor.countD.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.queueB.spark.yarn.lineC.spark.yarn.seatD.spark.yarn.priority
单项选择题以下哪项不属于Spark组件()
A.Spark SQLB.Spark StreamingC.PySparkD.SparkC
单项选择题RDD的默认Storage Level是()
A.MEMORY_ONLYB.MEMORY_AND_DISKC.MEMORY_ONLY_SERD.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)