A.GenericInMemoryCatalogB.JdbcCatalogC.HbaseCatalogD.HiveCatalog
单项选择题下列选项中属于Flink一致性定义的是()
A.at-most-onceB.exactly-onceC.ensure-onceD.absolutely-once
单项选择题Flink处理事件时间乱序使用的模型是()
A.WatermarkB.BatchmarkC.DelayHandlerD.RectifyHandler
单项选择题下列选项中属于Flink支持的时间模型的是()
A.EventTimeB.StartTimeC.LogTimeD.RemoteTime
单项选择题下列选项中不属于Flink内置State Backend的是()
A.MemoryStateBackendB.FsStateBackendC.RocksDBStateBackendD.DiskStateBackend
单项选择题下列有关Flink架构思想正确的是()
A.批是有界限的流B.流是微小的批C.使用批处理模拟流处理D.批和流无法统一
单项选择题下列选项中可以作为Flink集群HA解决方案的是()
A.NgixB.ConsoleC.ZookeeperD.HAProxy
单项选择题下列选项中不能作为Flink集群部署方式的是()
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