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
瀏覽器檢視
(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)檢視日誌