ÔØÈëÖС£¡£¡£ 'S bLog
 
ÔØÈëÖС£¡£¡£
 
ÔØÈëÖС£¡£¡£
ÔØÈëÖС£¡£¡£
ÔØÈëÖС£¡£¡£
ÔØÈëÖС£¡£¡£
ÔØÈëÖС£¡£¡£
 
ÌîдÄúµÄÓʼþµØÖ·£¬¶©ÔÄÎÒÃǵľ«²ÊÄÚÈÝ£º


 
»ùÓÚEclipseµÄHadoopÓ¦Óÿª·¢»·¾³µÄÅäÖÃ
[ 2011/4/30 19:09:00 | By: ÃÎÏè¶ù ]
 

»ùÓÚEclipseµÄHadoopÓ¦Óÿª·¢»·¾³µÄÅäÖÃ

ÅäÖúÃÁËHadoopÔËÐл·¾³£¬ÏÂÒ»²½¾ÍÒªÅäÖ㬿ª·¢»·¾³ÁË¡£Êµ¼ÊÉÏ¿ª·¢»·¾³ºÜºÃÅäÖã¬ÍøÉϺܶàµÄÌû×Ó£¬¶¼Ö¸ÏòÁËIBMÌṩµÄHadoop¿ª·¢¹¤¾ß£¬Õâ¸ö¹¤¾ßºÜºÃÓᣴó¼Ò´ò¿ªÕâ¸öÍøÖ·£¬ºÜÈÝÒ×¾ÍÄÜStep by step¸ã¶¨£¬http://www.alphaworks.ibm.com/tech/mapreducetools¡£µ«ÊÇϸÐĵĶÁÕß²»ÄÑ·¢ÏÖ£¬Õâ¸ö¹¤¾ßËÆºõÊǸö¾ø°æ£¬µ½ÏÖÔÚËÆºõ»¹ÊÇÍ£ÁôÔÚ2007Äê3ÔÂ23ÈÕÄØ£¬¶øÇÒÆäÖ§³ÖµÄEclipseÒ²ÊÇ3.3µÄ£¬Hadoop¸üÊÇ0.17µÄ¡£ºÜ¶àÈËÔÚforumÉÏ»¹±§Ô¹£¬°²×°ÉÏÕâ¸ö¹¤¾ßºó£¬±¨³ö´íÎó£ºRefresh DFS Children has encountered a problem£ºRefreshing DFS node failed: 1¡£ºÇºÇ£¬Õâ¸öÎÊÌâÎÒÒ²Óöµ½ÁË£¬ÎÒÒ²ºÜÓôÃÆ¡£ÎÒÐÄÀïÒ²ÔÚÂîIBMÕâ°ï¹ÙÁÅÈç´Ë²»Ë¼½øÈ¡¡£

ÕâÁ½ÌìÎÒÔÚ×°ÔØHadoop CoreµÄExamples²âÊÔ£¬ÓÉÓÚÏëÒª¶àÁ˽âЩHadoop£¬ÓÚÊǾʹò¿ªÁËHadoopµÄÿ¸ö×ÓĿ¼£¬ÔÚ´ò¿ª/hadoop-0.19.0/contrib/ÒâÍâ·¢ÏÖÁËeclipse-plugin£¬ÐÄÀï²»½ûÇÔϲ£¬²»ÖªµÀÊDz»ÊÇIBMµÄÕâ¸ö¹¤¾ßµÄÉý¼¶°æÒƵ½ÕâÀﻹÊÇÆäËûʲôԭÒò£¬¹¤¾ß²»ÊÇÔÚÕâÀïÂð£¿Ö»²»¹ýÓëÒÔǰ²»Í¬£¬ÊǸöjar°ü£¡ÎÒ°Ñhadoop-0.19.0-eclipse-plugin.jar£¬¿½±´µ½eclipse-SDK-3.4-win32\eclipse\pluginsÏÂÃæ£¬Æô¶¯eclipse£¬¾ÓÈ»ÕæµÄ°²×°³É¹¦ÁË£¬ÕæµÄÊǸù¤¾ßµÄÉý¼¶°æ£¬Ò²Ã»ÓÐÁËÄǸö´íÎó£¡ÕæµÄÊǺÜÒâÍ⣡½çÃæÊÇÕâÑùµÎ£¬Ñ¡ÔñWindow->Open Perspective£¬¿É¼ûµ½Ò»¸ö´°¿Ú£¬ÀïÃæÓÐÒ»¸öСÏóͼ±ê£ºMap/Reduce£¬µã»÷Ëü£¬»á´ò¿ªÒ»¸öеÄPerspective¡£È»ºóµã»÷Window->Show View£¬¿ÉÒÔ´ò¿ªÒ»¸öView£¬Èçͼ1Ëùʾ£¬

 

ͼ1


ÔÚÕâ¸öViewÖУ¬ÎÒÃÇ¿ÉÒÔ´´½¨Ò»¸ö»ò¶à¸öHadoopÔËÐл·¾³£¬Õâ¸öÔËÐл·¾³£¬ÓеãÏñ£¬ÔÚEclipseÖÐÅäÖÃJDBCÊý¾Ý¿âÁ¬½ÓÒ»Ñù¡£Èçͼ2£¬Í¼3Ëùʾ£º

 

ͼ2

ͼ3


ÅäÖÃÍê³ÉÒÔºó£¬ÏÔʾÈçͼ1×ó±ßµÄÊ÷ÐνṹһÑù£¬ÕâºÜÏñÔÚEclipseÅäÖÃÁË£¬TomcatµÄServerÏîĿһÑù¡£ÅäÖÃÍê³ÉÒÔºó£¬ÏÔʾÈçͼ1×ó±ßµÄÊ÷ÐνṹһÑù£¬ÕâºÜÏñÔÚEclipseÅäÖÃÁË£¬TomcatµÄServerÏîĿһÑù¡£

Äãµã»÷viewÖеÄСÏóͼ±ê£¬ºÜ¿ÉÄܻᱨһ¸ö´íÎó£º
Cannot connect to the Map/Reduce location: hadoop@ubuntu1
java.io.IOException: Unknown protocol to name node: org.apache.hadoop.mapred.JobSubmissionProtocol
 at org.apache.hadoop.dfs.NameNode.getProtocolVersion(NameNode.java:84)
 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)  at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
 at java.lang.reflect.Method.invoke(Method.java:585)
 at org.apache.hadoop.ipc.RPC$Server.call(RPC.java:452)
 at org.apache.hadoop.ipc.Server$Handler.run(Server.java:888)

ÎÒÒ²Óöµ½Õâ¸öÎÊÌ⣬ºÜÈÃÎÒÓôÃÆ£¬ÎÒÔ¸ÏëÊDz»ÊÇÎҵķþÎñÆ÷ÄÄÀï³öÁËÎÊÌ⣿ºóÀ´²ÅÖªµÀ£¬ÊÇÎҵĶ˿ÚÅäÖôíÎóÁË£¬ÎÒÔÚhadoop-site.xmlÖв»ÊÇÅäÖÃÁË:

<property>
<name>fs.default.name</name>
<value>hdfs://ubuntu1:9000</value>
</property>
<property>
<name>mapred.job.tracker</name>
<value>hdfs://ubuntu1:9001</value>
</property>

ÕâÁ½¸ö¶Ë¿ÚºÜÖØÒª£¬9000ÊÇnamenodeµÄ¼àÌý¶Ë¿Ú£¬¶ø9001ÊÇjobtrackerµÄ¼àÌý¶Ë¿Ú£¬ÔÚͼ3µÄ½çÃæÉÏн¨DFS locationʱºò£¬¿ÉÒÔ¿´µ½Map/Reduce Master£¬µ±Ê±ÎÒ»¹Ã»ÅªÃ÷°×£¬ÕâÊÇʲôÒâ˼£¬ÏÖÔÚ²ÅÖªµÀ£¬ÕâÊÇjobtrackerËùÔÚ»úÆ÷¼°¼àÌý¶Ë¿Ú£¬ÓÚÊÇÎÒÉèÖóɣºhost=ubuntu1,port=9001£¬¶øDFS MasterÖй´Ñ¡Use M/R Master Host£¨Òâ˼ÊÇ£ºÊÇ·ñʹÓÃÓëJobTrackerÏàͬµÄÖ÷»ú£¿£©Îҵĵ±È»Ê**´ÉÏ¡£¶Ë¿Úµ±È»Ò²¾ÍÊÇ9000ÁË£¬¼´host=ubuntu1£¬port=9000¡£

ÓÚÊÇ£¬Á¬½Óthe Map/Reduce location¾Í²»»áÔÙ³öÏÖ´íÎóÁË¡£ÏÂÃæµÄÓû§ÊÇcdh£¬ÒòΪÎÒµÄËùÓеÄubuntu¶¼ÊÇcdhµÄÓû§µÄ¡£


ÎÒÃÇ¿ÉÒÔÓÃWebµÄ·½Ê½À´²é¿´Õâ¸öÁ½¸ö¶Ë¿ÚÊÇ·ñ¹¤×÷Õý³££¬namenodeµÄWeb·ÃÎʶ˿ÚÊÇ50070£¬ÓÉÓÚÎÒµÄnamenodeÊǽ¨Á¢ÔÚubuntu1Éϵģ¬Òò´Ë£¬ÎÒÒªÓÃWeb·½Ê½·ÃÎÊnamenode£¬ÄÇôÔÚä¯ÀÀÆ÷ÖÐÇÃÈëµØÖ·£ºhttp://ubuntu1:50070£¬Äã¾Í»á¿´µ½Ò»¸öÒ³Ãæ£¬ÈçÏÂͼ4£º

ͼ4

 

¶ø9001ÊÇÒ²ÊÇ¿ÉÒÔÓÃWeb·½Ê½À´·ÃÎʵģ¬ÎÒµÄnamenodeºÍjobtrackerÊÇÔÚһ̨»úÆ÷Éϵģ¬ÍøÖ·ÊÇhttp://ubuntu1:50030£¬Èç¹ûÄãÅäÖóɹ¦£¬¿ÉÒÔ´ò¿ªÈçÏÂͼ5µÄÒ³Ãæ£º

ͼ5

tasktracker¿ÉÒÔWeb·½Ê½·ÃÎÊ£¬ÓÉÓÚÎÒµÄtasktrackerÊǽ¨Á¢ÔÚubuntu2Éϵģ¬Òò´ËÍøÖ·ÊÇ£ºhttp://ubuntu2:50060£¬Èç¹ûÄãÅäÖóɹ¦£¬¿ÉÒÔ´ò¿ªÈçÏÂͼ6µÄÒ³Ãæ£º

ͼ6

 

ΪÁËÄÜÕÒµ½±¾µØµÄHadoop°²×°Ä¿Â¼£¬´ò¿ªWindow->Preferences->Hadoop Map/Reduce£¬½«±¾µØµÄHadoop°²×°Ä¿Â¼Ìí¼Ó½øÀ´£¬Õâ¸ö°²×°Ä¿Â¼Êµ¼ÊÉϾÍÊǰÑhadoop-0.19.0.tar.gzÓýâѹ¹¤¾ß½âѹµ½Ò»¸öĿ¼ÏÂÃæ¡£Õâ¸öĿ¼¾ÍÊǰ²×°Ä¿Â¼¡£ÎҵľÍÊÇF:\hadoop-0.19.0¡£Èçͼ7Ëùʾ£º

ͼ7


µã»÷File->New->Other£¬ÔÚµ¯³öµÄ´°¿ÚÖлáÓÐMap/ReduceÏîÄ¿£¬Èçͼ8Ëùʾ£º

ͼ8

 

µã»÷ÏÂÒ»²½£¬Èçͼ9Ëùʾ£¬

ͼ9

 

ÔÙµã»÷ÏÂÒ»²½£¬Èçͼ10Ëùʾ£¬µã»÷Finish¾Í³ÉÁË¡£

ͼ10

 

ÓÒ¼üµã»÷×Ô¼ºËù´´½¨µÄÏîÄ¿£¬½øÈëµ½Properties£¬´ò¿ª½çÃæÈçͼ11Ëùʾ£¬¿ÉÒÔÔÚJava Build PathÖУ¬ÉèÖÃÔ´´úÂëºÍJava Doc·¾¶£¬ÕâÑù£¬Äã¾Í¿ÉÒÔ¿´µ½HadoopµÄËùÓÐCoreÔ´´úÂëÁË£¬ºÇºÇ

ͼ11


ÓÒ¼üµã»÷ÏîÄ¿ÖеÄsrc£¬¿ÉÒÔÌí¼ÓMapperÀ࣬ReducerÀ࣬ÒÔ¼°MapReducerDriverÀ࣬Ïòµ¼»á×Ô¶¯ÎªÄãÉú³ÉÕâÈý¸öÀàµÄFramework¡£Õâ¶ÔÓÚÐÂÊÖÓÈÆäÖØÒª¡£Èçͼ12Ëùʾ£º

ͼ12


±àдÍêÄãµÄ´úÂëÒÔºó£¬Äã¿ÉÒÔµã»÷ÄãµÄDriverÀà->Run on hadoop£¬À´ÔËÐÐÄãµÄHadoopÓ¦Óã¬Õâ¸öÔËÐÐÊ**¤¾ß×Ô¶¯´ò°ü³Éjar£¬²¿Êðµ½Hadoop»·¾³ÉÏÈ¥ÔËÐеġ£ºÇºÇ£¬ÖÁ´Ë£¬¿ª·¢»·¾³¾ÍÅäÖúÃÁË£¬Äã¿ÉÒÔ¾¡Ç鵨ÏíÓÃHadoop´ø¸øÄãµÄ¿ìÀÖÁË£¡

http://blog.sina.com.cn/s/blog_537770820100byho.html

 
 
  • ±êÇ©£ºEclipse Hadoop 
  • ·¢±íÆÀÂÛ£º
    ÔØÈëÖС£¡£¡£

     
     
     

    ÃÎÏè¶ùÍøÕ¾ ÃηÉÏèµÄµØ·½ http://www.dreamflier.net
    ÖлªÈËÃñ¹²ºÍ¹úÐÅÏ¢²úÒµ²¿TCP/IPϵͳ ±¸°¸ÐòºÅ£ºÁÉICP±¸09000550ºÅ

    Powered by Oblog.