一、簡答題

1.Spark master使用zookeeper進行HA的，有哪些元數(shù)據(jù)保存在Zookeeper？
答：spark通過這個參數(shù)spark.deploy.zookeeper.dir指定master元數(shù)據(jù)在zookeeper中保存的位置，包括Worker，Driver和Application以及Executors。standby節(jié)點要從zk中，獲得元數(shù)據(jù)信息，恢復(fù)集群運行狀態(tài)，才能對外繼續(xù)提供服務(wù)，作業(yè)提交資源申請等，在恢復(fù)前是不能接受請求的。另外，Master切換需要注意2點
1）在Master切換的過程中，所有的已經(jīng)在運行的程序皆正常運行！因為Spark Application在運行前就已經(jīng)通過Cluster Manager獲得了計算資源，所以在運行時Job本身的調(diào)度和處理和Master是沒有任何關(guān)系的！
2） 在Master的切換過程中唯一的影響是不能提交新的Job：一方面不能夠提交新的應(yīng)用程序給集群，因為只有Active Master才能接受新的程序的提交請求；另外一方面，已經(jīng)運行的程序中也不能夠因為Action操作觸發(fā)新的Job的提交請求；

2.Spark master HA 主從切換過程不會影響集群已有的作業(yè)運行，為什么？
答：因為程序在運行之前，已經(jīng)申請過資源了，driver和Executors通訊，不需要和master進行通訊的。

3.Spark on Mesos中，什么是的粗粒度分配，什么是細粒度分配，各自的優(yōu)點和缺點是什么？
答：1）粗粒度：啟動時就分配好資源， 程序啟動，后續(xù)具體使用就使用分配好的資源，不需要再分配資源；好處：作業(yè)特別多時，資源復(fù)用率高，適合粗粒度；不好：容易資源浪費，假如一個job有1000個task，完成了999個，還有一個沒完成，那么使用粗粒度，999個資源就會閑置在那里，資源浪費。2）細粒度分配：用資源的時候分配，用完了就立即回收資源，啟動會麻煩一點，啟動一次分配一次，會比較麻煩。

4.如何配置spark master的HA？
1)配置zookeeper
2)修改spark_env.sh文件,spark的master參數(shù)不在指定，添加如下代碼到各個master節(jié)點
export SPARK_DAEMON_JAVA_OPTS="-Dspark.deploy.recoveryMode=ZOOKEEPER -Dspark.deploy.zookeeper.url=zk01:2181,zk02:2181,zk03:2181 -Dspark.deploy.zookeeper.dir=/spark"
3) 將spark_env.sh分發(fā)到各個節(jié)點
4)找到一個master節(jié)點，執(zhí)行./start-all.sh，會在這里啟動主master,其他的master備節(jié)點，啟動master命令: ./sbin/start-master.sh
5)提交程序的時候指定master的時候要指定三臺master，例如
./spark-shell --master spark://master01:7077,master02:7077,master03:7077

5.Apache Spark有哪些常見的穩(wěn)定版本，Spark1.6.0的數(shù)字分別代表什么意思？
答：常見的大的穩(wěn)定版本有Spark 1.3,Spark1.6, Spark 2.0 ，Spark1.6.0的數(shù)字含義
1）第一個數(shù)字：1
major version : 代表大版本更新，一般都會有一些 api 的變化，以及大的優(yōu)化或是一些結(jié)構(gòu)的改變；
2）第二個數(shù)字：6
minor version : 代表小版本更新，一般會新加 api，或者是對當(dāng)前的 api 就行優(yōu)化，或者是其他內(nèi)容的更新，比如說 WEB UI 的更新等等；
3）第三個數(shù)字：0
patch version ， 代表修復(fù)當(dāng)前小版本存在的一些 bug，基本不會有任何 api 的改變和功能更新；記得有一個大神曾經(jīng)說過，如果要切換 spark 版本的話，最好選 patch version 非 0 的版本，因為一般類似于 1.2.0, … 1.6.0 這樣的版本是屬于大更新的，有可能會有一些隱藏的 bug 或是不穩(wěn)定性存在，所以最好選擇 1.2.1, … 1.6.1 這樣的版本。
通過版本號的解釋說明，可以很容易了解到，spark2.1.1的發(fā)布時是針對大版本2.1做的一些bug修改，不會新增功能，也不會新增API，會比2.1.0版本更加穩(wěn)定。

6.driver的功能是什么？
答： 1）一個Spark作業(yè)運行時包括一個Driver進程，也是作業(yè)的主進程，具有main函數(shù)，并且有SparkContext的實例，是程序的人口點；2）功能：負責(zé)向集群申請資源，向master注冊信息，負責(zé)了作業(yè)的調(diào)度，，負責(zé)作業(yè)的解析、生成Stage并調(diào)度Task到Executor上。包括DAGScheduler，TaskScheduler。

7.spark的有幾種部署模式，每種模式特點？
1）本地模式
Spark不一定非要跑在hadoop集群，可以在本地，起多個線程的方式來指定。將Spark應(yīng)用以多線程的方式直接運行在本地，一般都是為了方便調(diào)試，本地模式分三類
• local：只啟動一個executor
• local[k]:啟動k個executor
• local[*]：啟動跟cpu數(shù)目相同的 executor
2)standalone模式
分布式部署集群， 自帶完整的服務(wù)，資源管理和任務(wù)監(jiān)控是Spark自己監(jiān)控，這個模式也是其他模式的基礎(chǔ)，
3)Spark on yarn模式
分布式部署集群，資源和任務(wù)監(jiān)控交給yarn管理，但是目前僅支持粗粒度資源分配方式，包含cluster和client運行模式，cluster適合生產(chǎn)，driver運行在集群子節(jié)點，具有容錯功能，client適合調(diào)試，dirver運行在客戶端
4）Spark On Mesos模式。官方推薦這種模式（當(dāng)然，原因之一是血緣關(guān)系）。正是由于Spark開發(fā)之初就考慮到支持Mesos，因此，目前而言，Spark運行在Mesos上會比運行在YARN上更加靈活，更加自然。用戶可選擇兩種調(diào)度模式之一運行自己的應(yīng)用程序：
1) 粗粒度模式（Coarse-grained Mode）：每個應(yīng)用程序的運行環(huán)境由一個Dirver和若干個Executor組成，其中，每個Executor占用若干資源，內(nèi)部可運行多個Task（對應(yīng)多少個“slot”）。應(yīng)用程序的各個任務(wù)正式運行之前，需要將運行環(huán)境中的資源全部申請好，且運行過程中要一直占用這些資源，即使不用，最后程序運行結(jié)束后，回收這些資源。
2) 細粒度模式（Fine-grained Mode）：鑒于粗粒度模式會造成大量資源浪費，Spark On Mesos還提供了另外一種調(diào)度模式：細粒度模式，這種模式類似于現(xiàn)在的云計算，思想是按需分配。

8.Spark技術(shù)棧有哪些組件，每個組件都有什么功能，適合什么應(yīng)用場景？
答：可以畫一個這樣的技術(shù)棧圖先，然后分別解釋下每個組件的功能和場景

1）Spark core：是其它組件的基礎(chǔ)，spark的內(nèi)核，主要包含：有向循環(huán)圖、RDD、Lingage、Cache、broadcast等，并封裝了底層通訊框架，是Spark的基礎(chǔ)。
2）SparkStreaming是一個對實時數(shù)據(jù)流進行高通量、容錯處理的流式處理系統(tǒng)，可以對多種數(shù)據(jù)源（如Kdfka、Flume、Twitter、Zero和TCP 套接字）進行類似Map、Reduce和Join等復(fù)雜操作，將流式計算分解成一系列短小的批處理作業(yè)。
3）Spark sql：Shark是SparkSQL的前身，Spark SQL的一個重要特點是其能夠統(tǒng)一處理關(guān)系表和RDD，使得開發(fā)人員可以輕松地使用SQL命令進行外部查詢，同時進行更復(fù)雜的數(shù)據(jù)分析
4）BlinkDB ：是一個用于在海量數(shù)據(jù)上運行交互式 SQL 查詢的大規(guī)模并行查詢引擎，它允許用戶通過權(quán)衡數(shù)據(jù)精度來提升查詢響應(yīng)時間，其數(shù)據(jù)的精度被控制在允許的誤差范圍內(nèi)。
5）MLBase是Spark生態(tài)圈的一部分專注于機器學(xué)習(xí)，讓機器學(xué)習(xí)的門檻更低，讓一些可能并不了解機器學(xué)習(xí)的用戶也能方便地使用MLbase。MLBase分為四部分：MLlib、MLI、ML Optimizer和MLRuntime。
6）GraphX是Spark中用于圖和圖并行計算

9.Spark中Work的主要工作是什么？
答：主要功能：管理當(dāng)前節(jié)點內(nèi)存，CPU的使用狀況，接收master分配過來的資源指令，通過ExecutorRunner啟動程序分配任務(wù)，worker就類似于包工頭，管理分配新進程，做計算的服務(wù)，相當(dāng)于process服務(wù)。需要注意的是：1）worker會不會匯報當(dāng)前信息給master，worker心跳給master主要只有workid，它不會發(fā)送資源信息以心跳的方式給mater，master分配的時候就知道work，只有出現(xiàn)故障的時候才會發(fā)送資源。2）worker不會運行代碼，具體運行的是Executor是可以運行具體appliaction寫的業(yè)務(wù)邏輯代碼，操作代碼的節(jié)點，它不會運行程序的代碼的。

10.Spark為什么比mapreduce快？
答：1）基于內(nèi)存計算，減少低效的磁盤交互；2）高效的調(diào)度算法，基于DAG；3)容錯機制Linage，精華部分就是DAG和Lingae

11.簡單說一下hadoop和spark的shuffle相同和差異？
答：1）從 high-level 的角度來看，兩者并沒有大的差別。 都是將 mapper（Spark 里是 ShuffleMapTask）的輸出進行 partition，不同的 partition 送到不同的 reducer（Spark 里 reducer 可能是下一個 stage 里的 ShuffleMapTask，也可能是 ResultTask）。Reducer 以內(nèi)存作緩沖區(qū)，邊 shuffle 邊 aggregate 數(shù)據(jù)，等到數(shù)據(jù) aggregate 好以后進行 reduce() （Spark 里可能是后續(xù)的一系列操作）。
2）從 low-level 的角度來看，兩者差別不小。 Hadoop MapReduce 是 sort-based，進入 combine() 和 reduce() 的 records 必須先 sort。這樣的好處在于 combine/reduce() 可以處理大規(guī)模的數(shù)據(jù)，因為其輸入數(shù)據(jù)可以通過外排得到（mapper 對每段數(shù)據(jù)先做排序，reducer 的 shuffle 對排好序的每段數(shù)據(jù)做歸并）。目前的 Spark 默認選擇的是 hash-based，通常使用 HashMap 來對 shuffle 來的數(shù)據(jù)進行 aggregate，不會對數(shù)據(jù)進行提前排序。如果用戶需要經(jīng)過排序的數(shù)據(jù)，那么需要自己調(diào)用類似 sortByKey() 的操作；如果你是Spark 1.1的用戶，可以將spark.shuffle.manager設(shè)置為sort，則會對數(shù)據(jù)進行排序。在Spark 1.2中，sort將作為默認的Shuffle實現(xiàn)。
3）從實現(xiàn)角度來看，兩者也有不少差別。 Hadoop MapReduce 將處理流程劃分出明顯的幾個階段：map(), spill, merge, shuffle, sort, reduce() 等。每個階段各司其職，可以按照過程式的編程思想來逐一實現(xiàn)每個階段的功能。在 Spark 中，沒有這樣功能明確的階段，只有不同的 stage 和一系列的 transformation()，所以 spill, merge, aggregate 等操作需要蘊含在 transformation() 中。
如果我們將 map 端劃分數(shù)據(jù)、持久化數(shù)據(jù)的過程稱為 shuffle write，而將 reducer 讀入數(shù)據(jù)、aggregate 數(shù)據(jù)的過程稱為 shuffle read。那么在 Spark 中，問題就變?yōu)樵趺丛?job 的邏輯或者物理執(zhí)行圖中加入 shuffle write 和 shuffle read 的處理邏輯？以及兩個處理邏輯應(yīng)該怎么高效實現(xiàn)？
Shuffle write由于不要求數(shù)據(jù)有序，shuffle write 的任務(wù)很簡單：將數(shù)據(jù) partition 好，并持久化。之所以要持久化，一方面是要減少內(nèi)存存儲空間壓力，另一方面也是為了 fault-tolerance。

12.Mapreduce和Spark的都是并行計算，那么他們有什么相同和區(qū)別
答：兩者都是用mr模型來進行并行計算:
1)hadoop的一個作業(yè)稱為job，job里面分為map task和reduce task，每個task都是在自己的進程中運行的，當(dāng)task結(jié)束時，進程也會結(jié)束。
2)spark用戶提交的任務(wù)成為application，一個application對應(yīng)一個sparkcontext，app中存在多個job，每觸發(fā)一次action操作就會產(chǎn)生一個job。這些job可以并行或串行執(zhí)行，每個job中有多個stage，stage是shuffle過程中DAGSchaduler通過RDD之間的依賴關(guān)系劃分job而來的，每個stage里面有多個task，組成taskset有TaskSchaduler分發(fā)到各個executor中執(zhí)行，executor的生命周期是和app一樣的，即使沒有job運行也是存在的，所以task可以快速啟動讀取內(nèi)存進行計算。
3)hadoop的job只有map和reduce操作，表達能力比較欠缺而且在mr過程中會重復(fù)的讀寫hdfs，造成大量的io操作，多個job需要自己管理關(guān)系。
spark的迭代計算都是在內(nèi)存中進行的，API中提供了大量的RDD操作如join，groupby等，而且通過DAG圖可以實現(xiàn)良好的容錯。

13.RDD機制？
答：rdd分布式彈性數(shù)據(jù)集，簡單的理解成一種數(shù)據(jù)結(jié)構(gòu)，是spark框架上的通用貨幣。
所有算子都是基于rdd來執(zhí)行的，不同的場景會有不同的rdd實現(xiàn)類，但是都可以進行互相轉(zhuǎn)換。
rdd執(zhí)行過程中會形成dag圖，然后形成lineage保證容錯性等。 從物理的角度來看rdd存儲的是block和node之間的映射。

14、spark有哪些組件？
答：主要有如下組件：
1）master：管理集群和節(jié)點，不參與計算。
2）worker：計算節(jié)點，進程本身不參與計算，和master匯報。
3）Driver：運行程序的main方法，創(chuàng)建spark context對象。
4）spark context：控制整個application的生命周期，包括dagsheduler和task scheduler等組件。
5）client：用戶提交程序的入口。

15、spark工作機制？
答：用戶在client端提交作業(yè)后，會由Driver運行main方法并創(chuàng)建spark context上下文。
執(zhí)行add算子，形成dag圖輸入dagscheduler，按照add之間的依賴關(guān)系劃分stage輸入task scheduler。 task scheduler會將stage劃分為task set分發(fā)到各個節(jié)點的executor中執(zhí)行。

16、spark的優(yōu)化怎么做？
答： spark調(diào)優(yōu)比較復(fù)雜，但是大體可以分為三個方面來進行，1）平臺層面的調(diào)優(yōu)：防止不必要的jar包分發(fā)，提高數(shù)據(jù)的本地性，選擇高效的存儲格式如parquet，2）應(yīng)用程序?qū)用娴恼{(diào)優(yōu)：過濾操作符的優(yōu)化降低過多小任務(wù)，降低單條記錄的資源開銷，處理數(shù)據(jù)傾斜，復(fù)用RDD進行緩存，作業(yè)并行化執(zhí)行等等，3）JVM層面的調(diào)優(yōu)：設(shè)置合適的資源量，設(shè)置合理的JVM，啟用高效的序列化方法如kyro，增大off head內(nèi)存等等

17.簡要描述Spark分布式集群搭建的步驟
1）準備linux環(huán)境，設(shè)置集群搭建賬號和用戶組，設(shè)置ssh，關(guān)閉防火墻，關(guān)閉seLinux，配置host，hostname
2）配置jdk到環(huán)境變量
3）搭建hadoop集群，如果要做master ha，需要搭建zookeeper集群
修改hdfs-site.xml,hadoop_env.sh,yarn-site.xml,slaves等配置文件
4）啟動hadoop集群，啟動前要格式化namenode
5）配置spark集群，修改spark-env.xml，slaves等配置文件，拷貝hadoop相關(guān)配置到spark conf目錄下
6)啟動spark集群。

18.什么是RDD寬依賴和窄依賴？
RDD和它依賴的parent RDD(s)的關(guān)系有兩種不同的類型，即窄依賴（narrow dependency）和寬依賴（wide dependency）。
1）窄依賴指的是每一個parent RDD的Partition最多被子RDD的一個Partition使用
2）寬依賴指的是多個子RDD的Partition會依賴同一個parent RDD的Partition

19.spark-submit的時候如何引入外部jar包
方法一：spark-submit –jars
根據(jù)spark官網(wǎng)，在提交任務(wù)的時候指定–jars，用逗號分開。這樣做的缺點是每次都要指定jar包，如果jar包少的話可以這么做，但是如果多的話會很麻煩。
命令：spark-submit --master yarn-client --jars .jar,.jar
方法二：extraClassPath
提交時在spark-default中設(shè)定參數(shù)，將所有需要的jar包考到一個文件里，然后在參數(shù)中指定該目錄就可以了，較上一個方便很多：
spark.executor.extraClassPath=/home/hadoop/wzq_workspace/lib/* spark.driver.extraClassPath=/home/hadoop/wzq_workspace/lib/*
需要注意的是,你要在所有可能運行spark任務(wù)的機器上保證該目錄存在，并且將jar包考到所有機器上。這樣做的好處是提交代碼的時候不用再寫一長串jar了，缺點是要把所有的jar包都拷一遍。

20.cache和pesist的區(qū)別
答：1）cache和persist都是用于將一個RDD進行緩存的，這樣在之后使用的過程中就不需要重新計算了，可以大大節(jié)省程序運行時間；2） cache只有一個默認的緩存級別MEMORY_ONLY ，cache調(diào)用了persist，而persist可以根據(jù)情況設(shè)置其它的緩存級別；3）executor執(zhí)行的時候，默認60%做cache，40%做task操作，persist最根本的函數(shù)，最底層的函數(shù)

二、選擇題

1.Spark 的四大組件下面哪個不是 (D )
A.Spark Streaming B. Mlib
C Graphx D.Spark R

2.下面哪個端口不是 spark 自帶服務(wù)的端口 (C )
A.8080 B.4040 C.8090 D.18080
備注：8080：spark集群web ui端口，4040：sparkjob監(jiān)控端口，18080：jobhistory端口

3.spark 1.4 版本的最大變化 (B )
A spark sql Release 版本 B .引入 Spark R
C DataFrame D.支持動態(tài)資源分配

4.Spark Job 默認的調(diào)度模式 (A )
A FIFO B FAIR
C 無 D 運行時指定

5.哪個不是本地模式運行的個條件 ( D)
A spark.localExecution.enabled=true
B 顯式指定本地運行
C finalStage 無父 Stage
D partition默認值

6.下面哪個不是 RDD 的特點 (C )
A. 可分區(qū) B 可序列化 C 可修改 D 可持久化

7.關(guān)于廣播變量，下面哪個是錯誤的 (D )
A 任何函數(shù)調(diào)用 B 是只讀的
C 存儲在各個節(jié)點 D 存儲在磁盤或 HDFS

8.關(guān)于累加器，下面哪個是錯誤的 (D )
A 支持加法 B 支持數(shù)值類型
C 可并行 D 不支持自定義類型

9.Spark 支持的分布式部署方式中哪個是錯誤的 (D )
A standalone B spark on mesos
C spark on YARN D Spark on local

10.Stage 的 Task 的數(shù)量由什么決定 (A )
A Partition B Job C Stage D TaskScheduler

11.下面哪個操作是窄依賴 (B )
A join B filter
C group D sort

12.下面哪個操作肯定是寬依賴 (C )
A map B flatMap
C reduceByKey D sample

13.spark 的 master 和 worker 通過什么方式進行通信的？ (D )
A http B nio C netty D Akka

14 默認的存儲級別 (A )
A MEMORY_ONLY B MEMORY_ONLY_SER
C MEMORY_AND_DISK D MEMORY_AND_DISK_SER

15 spark.deploy.recoveryMode 不支持那種 (D )
A.ZooKeeper B. FileSystem
D NONE D Hadoop

16.下列哪個不是 RDD 的緩存方法 (C )
A persist() B Cache()
C Memory()

17.Task 運行在下來哪里個選項中 Executor 上的工作單元 (C )
A Driver program B. spark master
C.worker node D Cluster manager

18.hive 的元數(shù)據(jù)存儲在 derby 和 MySQL 中有什么區(qū)別 (B )
A.沒區(qū)別 B.多會話
C.支持網(wǎng)絡(luò)環(huán)境 D數(shù)據(jù)庫的區(qū)別

19.DataFrame 和 RDD 最大的區(qū)別 (B )
A.科學(xué)統(tǒng)計支持 B.多了 schema
C.存儲方式不一樣 D.外部數(shù)據(jù)源支持

20.Master 的 ElectedLeader 事件后做了哪些操作 (D )
A. 通知 driver B.通知 worker
C.注冊 application D.直接 ALIVE