1. 程式人生 > >Hadoop執行模式

Hadoop執行模式

1)官方網址

(1)官方網站:
    http://hadoop.apache.org/
(2)各個版本歸檔庫地址
    https://archive.apache.org/dist/hadoop/common/hadoop-2.7.4/
(3)hadoop2.7.4版本詳情介紹
    http://hadoop.apache.org/docs/r2.7.4/

2)Hadoop執行模式

(1)本地模式(預設模式):
    不需要啟用單獨程序,直接可以執行,測試和開發時使用。
(2)偽分散式模式:
    等同於完全分散式,只有一個節點。
(3)完全分散式模式:
    多個節點一起執行。

3)執行Hadoop 案例

3.1 本地檔案執行Hadoop 案例
3.1.1 官方grep案例
1)建立在hadoop-2.7.4檔案下面建立一個input資料夾

        [[email protected] hadoop-2.7.4]$ mkdir input

2)將hadoop的xml配置檔案複製到input

[[email protected] hadoop-2.7.4]$ cp etc/hadoop/*.xml input/

3)執行share目錄下的mapreduce程式

    [[email protected] hadoop-2.7.4]$ bin/hadoop jar share/hadoop/mapreduce/hadoop-mapreduce-examples-2.7.4.jar  grep input output 'dfs[a-z.]+'

4)檢視輸出結果

[[email protected] hadoop-2.7.4]$ cat output/*

3.1.2 官方wordcount案例
1)建立在hadoop-2.7.4檔案下面建立一個wcinput資料夾

[[email protected] hadoop-2.7.4]$ mkdir wcinput

2)在wcinput檔案下建立一個wc.input檔案

[[email protected] wcinput]$ touch wc.input

3)編輯wc.input檔案

[[email protected]
hadoop-2.7.4]$ vim wc.input hadoop yarn hadoop mapreduce zhihua zhihua xiaoming xiaoxiao daxiong daxiong daxiong

4)回到hadoop目錄/opt/module/hadoop-2.7.4

5)執行程式:

[[email protected] hadoop-2.7.4]$ bin/hadoop jar share/hadoop/mapreduce/hadoop-mapreduce-examples-2.7.4.jar  wordcount wcinput wcoutput

6)檢視結果:

[[email protected] hadoop-2.7.4]$ cat wcoutput/p*   
daxiong 3
hadoop  2
mapreduce   1
xiaoming    1
xiaoxiao    1
yarn    1
zhihua  2

3.2 偽分散式執行Hadoop案例

3.2.1 啟動HDFS並執行MapReduce程式
1)分析:

    (1)準備1臺客戶機
    (2)安裝jdk
    (3)配置環境變數
    (4)安裝hadoop
    (5)配置環境變數
    (6)配置叢集
    (7)啟動、測試叢集增、刪、查
    (8)執行wordcount案例

2)執行步驟
(1)配置叢集

(a)配置:hadoop-env.sh

修改JAVA_HOME 路徑:
這裡寫圖片描述

(b)配置:core-site.xml

<!-- 指定HDFS中NameNode的地址 -->
<property>
    <name>fs.defaultFS</name>
    <value>hdfs://hadoop101:9000</value>
</property>

<!-- 指定hadoop執行時產生檔案的儲存目錄 -->
<property>
    <name>hadoop.tmp.dir</name>
    <value>/opt/module/hadoop-2.7.4/data/tmp</value>
</property>

這裡寫圖片描述

(c)配置:hdfs-site.xml

<!-- 指定HDFS副本的數量 -->
    <property>
        <name>dfs.replication</name>
        <value>1</value>
    </property>

這裡寫圖片描述

(2)啟動叢集
(a)格式化namenode(第一次啟動時格式化,以後就不要總格式化)

bin/hdfs namenode -format

(b)啟動namenode

sbin/hadoop-daemon.sh start namenode

(c)啟動datanode

sbin/hadoop-daemon.sh start datanode

(3)檢視叢集
(a)檢視是否啟動成功

[[email protected] hadoop-2.7.4]# jps
2761 Jps
2586 NameNode
2686 DataNode

(b)檢視產生的log日誌

(c)web端檢視HDFS檔案系統

http://hadoop101:50070/dfshealth.html#tab-overview

注意:如果不能檢視,看如下帖子處理
http://www.cnblogs.com/zlslch/p/6604189.html

(4)操作叢集
(a)在hdfs檔案系統上建立一個input資料夾

    [[email protected] hadoop-2.7.4]# hadoop fs -mkdir -p /user/zhihua/input

    檢視資料夾
    [[email protected] hadoop-2.7.4]# hadoop fs -lsr /

這裡寫圖片描述

(b)將測試檔案內容上傳到檔案系統上

[[email protected] hadoop-2.7.4]# hadoop fs -put wcinput/wc.input /user/zhihua/input

(c)檢視上傳的檔案是否正確

[[email protected] hadoop-2.7.4]# hadoop fs -cat /user/zhihua/input/wc.input

(d)執行mapreduce程式

[[email protected] hadoop-2.7.4]# bin/hadoop jar share/hadoop/mapreduce/hadoop-mapreduce-examples-2.7.4.jar  wordcount /user/zhihua/input /user/zhihua/outout

(e)檢視輸出結果

命令列檢視: 
[[email protected] hadoop-2.7.4]# hadoop fs -cat /user/zhihua/outout/p*
daxiong 3
hadoop  2
mapreduce   1
xiaoming    1
xiaoxiao    1
yarn    1
zhihua  2


瀏覽器檢視

瀏覽器檢視.png

(f)將測試檔案內容下載到本地

[[email protected] hadoop-2.7.4]# hadoop fs -get /user/zhihua/outout/p* ./

(g)刪除輸出結果

[[email protected] hadoop-2.7.4]# hadoop fs -rm -r /user/zhihua/outout

3.2.2 YARN上執行MapReduce 程式
1)分析:

(1)準備1臺客戶機
(2)安裝jdk
(3)配置環境變數
(4)安裝hadoop
(5)配置環境變數
(6)配置叢集yarn上執行
(7)啟動、測試叢集增、刪、查
(8)在yarn上執行wordcount案例

2)執行步驟
(1)配置叢集
(a)配置yarn-env.sh
配置一下JAVA_HOME
這裡寫圖片描述

(b)配置yarn-site.xml

<!-- reducer獲取資料的方式 -->
<property>
 <name>yarn.nodemanager.aux-services</name>
 <value>mapreduce_shuffle</value>
</property>

<!-- 指定YARN的ResourceManager的地址 -->
<property>
<name>yarn.resourcemanager.hostname</name>
<value>hadoop101</value>
</property>

這裡寫圖片描述

(c)配置:mapred-env.sh
配置一下JAVA_HOME
這裡寫圖片描述

(d)配置: (對mapred-site.xml.template重新命名為) mapred-site.xml

[[email protected] hadoop]# mv mapred-site.xml.template mapred-site.xml
<!-- 指定mr執行在yarn上 -->
    <property>
        <name>mapreduce.framework.name</name>
        <value>yarn</value>
    </property>

這裡寫圖片描述

(2)啟動叢集

(a)啟動resourcemanager

[[email protected] hadoop-2.7.4]# sbin/yarn-daemon.sh start resourcemanager

(b)啟動nodemanager

[[email protected] hadoop-2.7.4]# sbin/yarn-daemon.sh start nodemanager

(c)檢視jps

[[email protected] hadoop-2.7.4]# jps
4086 NodeManager
2586 NameNode
3834 ResourceManager
4122 Jps
2686 DataNode

(3)叢集操作
(a)yarn的瀏覽器頁面檢視

http://hadoop101:8088/cluster

(b)刪除檔案系統上的output檔案

    hadoop fs -rm -R /user/zhihua/output

(c)執行mapreduce程式

[[email protected] hadoop-2.7.4]# bin/hadoop jar share/hadoop/mapreduce/hadoop-mapreduce-examples-2.7.4.jar  wordcount /user/zhihua/input /user/zhihua/output

(d)檢視執行結果

[[email protected] hadoop-2.7.4]# hadoop fs -cat /user/zhihua/output/p*
daxiong 3
hadoop  2
mapreduce   1
xiaoming    1
xiaoxiao    1
yarn    1
zhihua  2

這裡寫圖片描述

3.2.3 修改本地臨時檔案儲存目錄
1)停止程序

    [[email protected] hadoop-2.7.4]$ sbin/yarn-daemon.sh stop nodemanager
    [[email protected] hadoop-2.7.4]$ sbin/yarn-daemon.sh stop resourcemanager
    [[email protected] hadoop-2.7.4]$ sbin/hadoop-daemon.sh stop datanode
    [[email protected] hadoop-2.7.4]$ sbin/hadoop-daemon.sh stop namenode

2)修改core-site.xml
這裡寫圖片描述

3)格式化NameNode

將/opt/module/hadoop-2.7.4路徑中的logs資料夾刪除掉
    [[email protected] hadoop-2.7.4]$ rm -rf logs/
進入到tmp目錄將tmp目錄中hadoop-atguigu目錄刪除掉
    [[email protected] hadoop-2.7.4]$ rm -rf hadoop-atguigu/
格式化資料:
    [[email protected] hadoop-2.7.4]$ bin/hdfs namenode -format

4)啟動所有程序

[[email protected] hadoop-2.7.4]$ sbin/hadoop-daemon.sh start namenode
[[email protected] hadoop-2.7.4]$ sbin/hadoop-daemon.sh start datanode
[[email protected] hadoop-2.7.4]$ sbin/yarn-daemon.sh start resourcemanager
[[email protected] hadoop-2.7.4]$ sbin/yarn-daemon.sh start nodemanager

5)檢視/opt/module/hadoop-2.7.4/data/tmp這個目錄下的內容。

3.2.4 Hadoop配置檔案說明
Hadoop配置檔案分兩類:預設配置檔案和自定義配置檔案,只有使用者想修改某一預設配置值時,才需要修改自定義配置檔案,更改相應屬性值。
(1)預設配置檔案:存放在hadoop相應的jar包中

[core-default.xml]
            hadoop-common-2.7.4.jar/ core-default.xml
        [hdfs-default.xml]
hadoop-hdfs-2.7.4.jar/ hdfs-default.xml
        [yarn-default.xml]
hadoop-yarn-common-2.7.4.jar/ yarn-default.xml
        [core-default.xml]
hadoop-mapreduce-client-core-2.7.4.jar/ core-default.xml

(2)自定義配置檔案:存放在$HADOOP_HOME/etc/hadoop

core-site.xml
hdfs-site.xml
yarn-site.xml
mapred-site.xml

3.2.5 歷史服務配置啟動檢視
1)配置mapred-site.xml

<property>
<name>mapreduce.jobhistory.address</name>
<value>hadoop101:10020</value>
</property>
<property>
    <name>mapreduce.jobhistory.webapp.address</name>
    <value>hadoop101:19888</value>
</property>

2)檢視啟動歷史伺服器檔案目錄:

[[email protected] hadoop-2.7.4]$ ll sbin/ |grep mr
-rwxr-xr-x. 1 zhihua zhihua 4080 Aug 23  2017 mr-jobhistory-daemon.sh

3)啟動歷史伺服器

[[email protected] hadoop-2.7.4]$ sbin/mr-jobhistory-daemon.sh start historyserver

4)檢視歷史伺服器是否啟動

[[email protected] hadoop-2.7.4]$ jps
3521 NameNode
3623 DataNode
3737 ResourceManager
3995 NodeManager
4157 JobHistoryServer
4239 Jps

5)檢視jobhistory

這裡寫圖片描述
這裡寫圖片描述

3.2.6 日誌的聚集
日誌聚集概念:應用執行完成以後,將日誌資訊上傳到HDFS系統上。
開啟日誌聚集功能步驟:
(1)配置yarn-site.xml

<!-- 日誌聚集功能使能 -->
<property>
<name>yarn.log-aggregation-enable</name>
<value>true</value>
</property>
<!-- 日誌保留時間設定7天 -->
<property>
<name>yarn.log-aggregation.retain-seconds</name>
<value>604800</value>
</property>

(2)關閉namenode、datanode 、nodemanager 、resourcemanager和historymanager

(3)啟動namenode、datanode 、nodemanager 、resourcemanager和historymanager

(4)刪除hdfs上已經存在的hdfs檔案

(5)執行wordcount程式

(6)檢視日誌
這裡寫圖片描述
這裡寫圖片描述
這裡寫圖片描述