老師,IDEA如何在本地運行和調試Hadoop程序?

2019-10-30     程式設計師聖經
作者:Tong ZHAN
來源:https://www.polarxiong.com/

前言

Hadoop可以運行在三種模式下:

  1. 單機模式
  2. 偽分布模式
  3. 完全分布式模式

相信初學者入門Hadoop的第一堂課就是偽分布模式Hadoop系統的安裝,相信一定是血淚史各種翻教程各種重裝。而實際上,基於Hadoop的MapReduce程序在單機上運行,並不一定需要安裝偽分布模式Hadoop系統,甚至,並不一定需要安裝Hadoop。

運行和調試MapReduce程序只需要有相應的Hadoop依賴包就行,可以完全當成一個普通的JAVA程序。本文就將介紹這種簡單方便的方法。

簡介

正如上文所說,在單機模式下,可以將MapReduce程序當成一個普通的JAVA程序;對比偽分布模式,其主要不足就在於沒有Hadoop的整個管理控制系統,如JobTracker面板,而只是用來運行和調試程序;而其優點就在於開發調試方便,編寫的程序通常不需要修改即可在真實的分布式Hadoop集群下運行

Maven

Maven是一個項目管理工具,我們這裡主要用到的是它的依賴管理系統。通常我們在開發Hadoop MapReduce程序時,首先要下載對應版本的鏡像,然後加載鏡像中的JAR依賴包,開始編寫代碼。這個步驟說起來容易但經常會碰到錯綜複雜的依賴關係,而利用Maven就能輕鬆解決這個問題。只需要在Maven配置文件中指定Hadoop依賴包名字和版本號,Maven就能自動搞定這些依賴,你只需要專心寫代碼就好了。

Intellij IDEA

為什麼不用Eclipse呢?這裡沒有貶低Eclipse的意思,只是我認為Eclipse用戶體驗太差,而且各種操作過於繁瑣。Intellij用起來更順手,內置了Maven的支持,而且看起來似乎更有前景,就使用Intellij了。

環境要求

  1. JDK 1.7(1.8似乎也可以,但Hadoop官方推薦1.7)
  2. Intellij

不需要安裝任何模式的Hadoop。

WordCount

這裡以Hadoop的官方示例程序WordCount為例,演示如何一步步編寫程序直到運行。

新建項目

在Intellij中點擊File->New->Project,在彈出的對話框中選擇Maven,JDK選擇1.7,點擊Next。

接下來填寫Maven的GroupId和ArtifactId,隨便填,點擊Next。

然後是Project name,這裡填寫WordCount,點擊Finish。

這樣就新建好了一個空的項目,別著急,還有一個地方可能需要修改。打開Intellij的Preference偏好設置,定位到Build, Execution, Deployment->Compiler->Java Compiler,將WordCount的Target bytecode version修改為1.7。

配置依賴

新建項目後,在Intellij左上方會有項目文件結構,雙擊以編輯pom.xml,這就是Maven的配置了。

添加源

pom.xml初始內容如下

在project內尾部添加




apache
http://maven.apache.org


添加apache源。

添加依賴


這裡只需要用到基礎依賴hadoop-core和hadoop-common;如果需要讀寫HDFS,則還需要依賴hadoop-hdfs和hadoop-client;如果需要讀寫HBase,則還需要依賴hbase-client。

在project內尾部添加

這裡hadoop-core的version一般為1.2.1,hadoop-common的version可以依照你的實際需要來。

修改pom.xml完成後,Intellij右上角會提示Maven projects need to be Imported,點擊Import Changes以更新依賴

附上完整的pom.xml

WordCount

在src->main->java下新建一個WordCount類,添加內容

此代碼來自Hadoop官方教程,出處見參考。

配置輸入文件

WordCount對輸入文件字符進行計數,輸出計數的結果。首先需要配置輸入路徑,這裡在WordCount下(src同級目錄)新建一個文件夾input,並添加一個或多個文本文件到input中,作為示例。

這裡還有一件事情,點擊File->Project Structure,在彈出來的對話框中選擇Modules項,點擊Sources選項卡,將Language level調整為7。(如果你用到版本控制的話,可以在這裡將input文件夾標記為Excluded。

配置運行參數

這裡我們需要配置此程序運行時的Main class,以及WordCount需要的輸入輸出路徑。

在Intellij菜單欄中選擇Run->Edit Configurations,在彈出來的對話框中點擊+,新建一個Application配置。配置Main class為WordCount(可以點擊右邊的...選擇),Program arguments為input/ output/,即輸入路徑為剛才創建的input文件夾,輸出為output。

運行和調試

運行

上述配置完成後,點擊菜單欄Run->Run 'WordCount'即開始運行此MapReduce程序,Intellij下方會顯示Hadoop的運行輸出。待程序運行完畢後,Intellij左上方會出現新的文件夾output,其中的part-r-00000就是運行的結果了!

由於Hadoop的設定,下次運行時務必刪除output文件夾!

調試

斷點調試也很容易,在需要設置的代碼前單擊加上斷點,點擊菜單欄Run->Debug 'WordCount'即開始調試,程序會在斷點處停下。

Windows下的權限問題

Windows下運行可能會出錯,提示

ERROR security.UserGroupInformation: PriviledgedActionException as ...

這是因為當前用戶沒有權限來設置路徑權限(Linux無此問題),一個解決方法是給hadoop打補丁,參考Failed to set permissions of path: tmp,因為這裡使用的Maven,此方法不太適合。另一個方法是將當前用戶設置為超級管理員(「計算機管理」,「本地用戶和組」中設置),或以超級管理員登錄運行此程序。

不過我覺得最好的解決方法是在Linux或macOS上跑hadoop。

小結

上面描述的步驟有些多,但邏輯上都是很清晰的,有過一次經驗以後就之後就容易多了,主要就是在pom.xml的配置和運行參數的配置上。刪除WordCount程序的運行不需要任何的Hadoop開發環境,並且依賴問題全部交給Maven解決了,怎麼樣?是不是非常簡單?

DEMO

本示例程序代碼放在Github上,參見zhantong/Hadoop-WordCount。

https://github.com/zhantong/Hadoop-WordCount

文章來源: https://twgreatdaily.com/zh-cn/6zRsJW4BMH2_cNUglHbY.html