Hadoop 在Windows7操作系统下使用Eclipse来搭建hadoop开发环境

矫情吗；* 2022-06-07 13:54 144阅读 0赞

网上有一些都是在Linux下使用安装Eclipse来进行hadoop应用开发，但是大部分Java程序员对linux系统不是那么熟悉，所以需要在windows下开发hadoop程序，所以经过试验，总结了下如何在windows下使用Eclipse来开发hadoop程序代码。

1、 需要下载hadoop的专门插件jar包

hadoop版本为2.3.0，hadoop集群搭建在centos6x上面，插件包下载地址为：[http://download.csdn.net/detail/mchdba/8267181，jar][http_download.csdn.net_detail_mchdba_8267181_jar]包名字为hadoop-eclipse-plugin-2.3.0，可以适用于hadoop2x系列软件版本。

2、 把插件包放到eclipse/plugins目录下

为了以后方便，我这里把尽可能多的jar包都放进来了，如下图所示：  
![26230597_1418733214H68z.png][]

3、重启eclipse，配置Hadoop installation directory

如果插件安装成功，打开Windows—Preferences后，在窗口左侧会有Hadoop Map/Reduce选项，点击此选项，在窗口右侧设置Hadoop安装路径。

![26230597_1418733303mmPw.png][]

4、配置Map/Reduce Locations

打开Windows-->Open Perspective-->Other

![26230597_1418733346JB29.png][]

选择Map/Reduce，点击OK，在右下方看到有个Map/Reduce Locations的图标，如下图所示：  
![26230597_1418733410HT6q.png][]

点击Map/Reduce Location选项卡，点击右边小象图标，打开Hadoop Location配置窗口：

输入Location Name，任意名称即可.配置Map/Reduce Master和DFS Mastrer，Host和Port配置成与core-site.xml的设置一致即可。

去找core-site.xml配置：

fs.default.name                                                                        hdfs://name01:9000

在界面配置如下：

![26230597_1418733500130j.png][]

点击"Finish"按钮，关闭窗口。点击左侧的DFSLocations—>myhadoop（上一步配置的location name)，如能看到user，表示安装成功，但是进去看到报错信息：Error: Permission denied: user=root,access=READ\_EXECUTE,inode="/tmp";hadoop:supergroup:drwx---------，如下图所示：

![26230597_14187335478qqi.png][]

应该是权限问题：把/tmp/目录下面所有的关于hadoop的文件夹设置成hadoop用户所有然后分配授予777权限。

cd /tmp/

chmod 777 /tmp/

chown -R hadoop.hadoop /tmp/hsperfdata\_root

之后重新连接打开DFS Locations就显示正常了。

Map/Reduce Master (此处为Hadoop集群的Map/Reduce地址，应该和mapred-site.xml中的mapred.job.tracker设置相同)

（1）：点击报错：

An internal error occurred during: "Connecting to DFS hadoopname01".

java.net.UnknownHostException: name01

直接在hostname那一栏里面设置ip地址为：192.168.52.128，即可，这样就正常打开了，如下图所示：  
![26230597_1418733645Oooo.png][]

5、新建WordCount项目

File—>Project，选择Map/Reduce Project，输入项目名称WordCount等。

在WordCount项目里新建class，名称为WordCount，报错代码如下：Invalid Hadoop Runtime specified; please click 'Configure Hadoop install directory' or fill in library location input field，报错原因是目录选择不对，不能选择在跟目录E:\\hadoop下，换成E:\\u\\hadoop\\就可以了，如下所示：

![26230597_1418733743B2yf.png][]

一路下一步过去，点击Finished按钮，完成工程创建，Eclipse控制台下面出现如下信息：

14-12-9 下午04时03分10秒: Eclipse is running in a JRE, but a JDK is required

Some Maven plugins may not work when importing projects or updating source folders.

14-12-9 下午04时03分13秒: Refreshing \[/WordCount/pom.xml\]

14-12-9 下午04时03分14秒: Refreshing \[/WordCount/pom.xml\]

14-12-9 下午04时03分14秒: Updating index central|http://repo1.maven.org/maven2

14-12-9 下午04时04分10秒: Updated index for central|http://repo1.maven.org/maven2

6， Lib包导入：  
需要添加的hadoop相应jar包有：

/hadoop-2.3.0/share/hadoop/common下所有jar包，及里面的lib目录下所有jar包，  
/hadoop-2.3.0/share/hadoop/hdfs下所有jar包，不包括里面lib下的jar包，  
/hadoop-2.3.0/share/hadoop/mapreduce下所有jar包，不包括里面lib下的jar包，  
/hadoop-2.3.0/share/hadoop/yarn下所有jar包，不包括里面lib下的jar包，  
大概18个jar包左右。

7，Eclipse直接提交mapreduce任务所需要环境配置代码如下所示：

1.  package wc;  
    
2.  import java.io.IOException;  
    
3.  import java.util.StringTokenizer;  
    
4.  import org.apache.hadoop.conf.Configuration;  
    
5.  import org.apache.hadoop.fs.Path;  
    
6.  import org.apache.hadoop.io.IntWritable;  
    
7.  import org.apache.hadoop.io.Text;  
    
8.  import org.apache.hadoop.mapreduce.Job;  
    
9.  import org.apache.hadoop.mapreduce.Mapper;  
    
10. import org.apache.hadoop.mapreduce.Reducer;  
    
11. import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;  
    
12. import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;  
    
13. import org.apache.hadoop.util.GenericOptionsParser;  
    
14.    
    
15. public class W2 \{   
    
16.   
    
17.     public static class TokenizerMapper extends  
    
18.             Mapper<Object, Text, Text, IntWritable> \{   
    
19.         private final static IntWritable one = new IntWritable(1);  
    
20.         private Text word = new Text();  
    
21.         public void map(Object key, Text value, Context context)  
    
22.                 throws IOException, InterruptedException \{   
    
23.             StringTokenizer itr = new StringTokenizer(value.toString());  
    
24.             while (itr.hasMoreTokens()) \{   
    
25.                 word.set(itr.nextToken());  
    
26.                 context.write(word, one);  
    
27.             \}  
    
28.         \}  
    
29.     \}  
    
30.    
    
31.     public static class IntSumReducer extends  
    
32.             Reducer<Text, IntWritable, Text, IntWritable> \{   
    
33.         private IntWritable result = new IntWritable();  
    
34.         public void reduce(Text key, Iterable<IntWritable> values,  
    
35.                 Context context) throws IOException, InterruptedException \{   
    
36.             int sum = 0;  
    
37.             for (IntWritable val : values) \{   
    
38.                 sum \+= val.get();  
    
39.             \}  
    
40.             result.set(sum);  
    
41.             context.write(key, result);  
    
42.         \}  
    
43.     \}  
    
44.    
    
45.     public static void main(String\[\] args) throws Exception \{   
    
46.    
    
47.         Configuration conf = new Configuration(); System.setProperty(\\

## 8、运行 ##

8.1、在HDFS上创建目录input

\[hadoop@name01 hadoop-2.3.0\]$ hadoop fs -ls /

\[hadoop@name01 hadoop-2.3.0\]$  hadoop fs -mkdir input

mkdir: \`input': No such file or directory

\[hadoop@name01 hadoop-2.3.0\]$ PS：fs需要全目录的方式来创建文件夹

如果Apache hadoop版本是0.x 或者1.x,

bin/hadoop hdfs fs -mkdir -p /in

bin/hadoop hdfs fs  -put /home/du/input   /in

如果Apache hadoop版本是2.x.

bin/hdfs  dfs  -mkdir -p /in

bin/hdfs  dfs   -put /home/du/input   /in

如果是发行版的hadoop,比如Cloudera CDH,IBM BI,Hortonworks HDP 则第一种命令即可。要注意创建目录的全路径。另外hdfs的根目录是 /

2、拷贝本地README.txt到HDFS的input里

\[hadoop@name01 hadoop-2.3.0\]$ find . -name README.txt

./share/doc/hadoop/common/README.txt

\[hadoop@name01 ~\]$ hadoop fs -copyFromLocal ./src/hadoop-2.3.0/share/doc/hadoop/common/README.txt /data/input

\[hadoop@name01 ~\]$

\[hadoop@name01 ~\]$ hadoop fs -ls /  
Found 2 items  
drwxr-xr-x   - hadoop supergroup          0 2014-12-15 23:34 /data  
\-rw-r--r--   3 hadoop supergroup         88 2014-08-26 02:21 /input  
You have new mail in /var/spool/mail/root  
\[hadoop@name01 ~\]$

3，运行hadoop结束后，查看输出结果  
（1），直接在hadoop服务器上面查看  
\[hadoop@name01 ~\]$ hadoop fs -ls /data/  
Found 2 items  
drwxr-xr-x   - hadoop supergroup          0 2014-12-15 23:29 /data/input  
drwxr-xr-x   - hadoop supergroup          0 2014-12-15 23:34 /data/output  
\[hadoop@name01 ~\]$   
  
（2），去Eclipse下查看  
![26230597_1418733974uMcj.png][]  
  
（3），在控制台上查看信息

1.  2014\-12\-16 15:34:01,303 INFO \[main\] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(996)) \- session.id is deprecated. Instead, use dfs.metrics.session\-id  
    
2.  2014\-12\-16 15:34:01,309 INFO \[main\] jvm.JvmMetrics (JvmMetrics.java:init(76)) \- Initializing JVM Metrics with processName=JobTracker, sessionId=  
    
3.  2014\-12\-16 15:34:02,047 INFO \[main\] input.FileInputFormat (FileInputFormat.java:listStatus(287)) \- Total input paths to process : 1  
    
4.  2014\-12\-16 15:34:02,120 INFO \[main\] mapreduce.JobSubmitter (JobSubmitter.java:submitJobInternal(396)) \- number of splits:1  
    
5.  2014\-12\-16 15:34:02,323 INFO \[main\] mapreduce.JobSubmitter (JobSubmitter.java:printTokens(479)) \- Submitting tokens for job: job\_local1764589720\_0001  
    
6.  2014\-12\-16 15:34:02,367 WARN \[main\] conf.Configuration (Configuration.java:loadProperty(2345)) \- file:/tmp/hadoop\-hadoop/mapred/staging/hadoop1764589720/.staging/job\_local1764589720\_0001/job.xml:an attempt to override final parameter: mapreduce.job.end\-notification.max.retry.interval; Ignoring.  
    
7.  2014\-12\-16 15:34:02,368 WARN \[main\] conf.Configuration (Configuration.java:loadProperty(2345)) \- file:/tmp/hadoop\-hadoop/mapred/staging/hadoop1764589720/.staging/job\_local1764589720\_0001/job.xml:an attempt to override final parameter: mapreduce.job.end\-notification.max.attempts; Ignoring.  
    
8.  2014\-12\-16 15:34:02,682 WARN \[main\] conf.Configuration (Configuration.java:loadProperty(2345)) \- file:/tmp/hadoop\-hadoop/mapred/local/localRunner/hadoop/job\_local1764589720\_0001/job\_local1764589720\_0001.xml:an attempt to override final parameter: mapreduce.job.end\-notification.max.retry.interval; Ignoring.  
    
9.  2014\-12\-16 15:34:02,682 WARN \[main\] conf.Configuration (Configuration.java:loadProperty(2345)) \- file:/tmp/hadoop\-hadoop/mapred/local/localRunner/hadoop/job\_local1764589720\_0001/job\_local1764589720\_0001.xml:an attempt to override final parameter: mapreduce.job.end\-notification.max.attempts; Ignoring.  
    
10. 2014\-12\-16 15:34:02,703 INFO \[main\] mapreduce.Job (Job.java:submit(1289)) \- The url to track the job: http://localhost:8080/  
    
11. 2014\-12\-16 15:34:02,704 INFO \[main\] mapreduce.Job (Job.java:monitorAndPrintJob(1334)) \- Running job: job\_local1764589720\_0001  
    
12. 2014\-12\-16 15:34:02,707 INFO \[Thread\-4\] mapred.LocalJobRunner (LocalJobRunner.java:createOutputCommitter(471)) \- OutputCommitter set in config null  
    
13. 2014\-12\-16 15:34:02,719 INFO \[Thread\-4\] mapred.LocalJobRunner (LocalJobRunner.java:createOutputCommitter(489)) \- OutputCommitter is org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter  
    
14. 2014\-12\-16 15:34:02,853 INFO \[Thread\-4\] mapred.LocalJobRunner (LocalJobRunner.java:runTasks(448)) \- Waiting for map tasks  
    
15. 2014\-12\-16 15:34:02,857 INFO \[LocalJobRunner Map Task Executor \#0\] mapred.LocalJobRunner (LocalJobRunner.java:run(224)) \- Starting task: attempt\_local1764589720\_0001\_m\_000000\_0  
    
16. 2014\-12\-16 15:34:02,919 INFO \[LocalJobRunner Map Task Executor \#0\] util.ProcfsBasedProcessTree (ProcfsBasedProcessTree.java:isAvailable(129)) \- ProcfsBasedProcessTree currently is supported only on Linux.  
    
17. 2014\-12\-16 15:34:03,281 INFO \[LocalJobRunner Map Task Executor \#0\] mapred.Task (Task.java:initialize(581)) \- Using ResourceCalculatorProcessTree : org.apache.hadoop.yarn.util.WindowsBasedProcessTree@2e1022ec  
    
18. 2014\-12\-16 15:34:03,287 INFO \[LocalJobRunner Map Task Executor \#0\] mapred.MapTask (MapTask.java:runNewMapper(733)) \- Processing split: hdfs://192.168.52.128:9000/data/input/README.txt:0\+1366  
    
19. 2014\-12\-16 15:34:03,304 INFO \[LocalJobRunner Map Task Executor \#0\] mapred.MapTask (MapTask.java:createSortingCollector(388)) \- Map output collector class = org.apache.hadoop.mapred.MapTask$MapOutputBuffer  
    
20. 2014\-12\-16 15:34:03,340 INFO \[LocalJobRunner Map Task Executor \#0\] mapred.MapTask (MapTask.java:setEquator(1181)) \- (EQUATOR) 0 kvi 26214396(104857584)  
    
21. 2014\-12\-16 15:34:03,341 INFO \[LocalJobRunner Map Task Executor \#0\] mapred.MapTask (MapTask.java:init(975)) \- mapreduce.task.io.sort.mb: 100  
    
22. 2014\-12\-16 15:34:03,341 INFO \[LocalJobRunner Map Task Executor \#0\] mapred.MapTask (MapTask.java:init(976)) \- soft limit at 83886080  
    
23. 2014\-12\-16 15:34:03,341 INFO \[LocalJobRunner Map Task Executor \#0\] mapred.MapTask (MapTask.java:init(977)) \- bufstart = 0; bufvoid = 104857600  
    
24. 2014\-12\-16 15:34:03,341 INFO \[LocalJobRunner Map Task Executor \#0\] mapred.MapTask (MapTask.java:init(978)) \- kvstart = 26214396; length = 6553600  
    
25. 2014\-12\-16 15:34:03,708 INFO \[main\] mapreduce.Job (Job.java:monitorAndPrintJob(1355)) \- Job job\_local1764589720\_0001 running in uber mode : false  
    
26. 2014\-12\-16 15:34:03,710 INFO \[main\] mapreduce.Job (Job.java:monitorAndPrintJob(1362)) \- map 0% reduce 0%  
    
27. 2014\-12\-16 15:34:04,121 INFO \[LocalJobRunner Map Task Executor \#0\] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(591)) \-   
    
28. 2014\-12\-16 15:34:04,128 INFO \[LocalJobRunner Map Task Executor \#0\] mapred.MapTask (MapTask.java:flush(1435)) \- Starting flush of map output  
    
29. 2014\-12\-16 15:34:04,128 INFO \[LocalJobRunner Map Task Executor \#0\] mapred.MapTask (MapTask.java:flush(1453)) \- Spilling map output  
    
30. 2014\-12\-16 15:34:04,128 INFO \[LocalJobRunner Map Task Executor \#0\] mapred.MapTask (MapTask.java:flush(1454)) \- bufstart = 0; bufend = 2055; bufvoid = 104857600  
    
31. 2014\-12\-16 15:34:04,128 INFO \[LocalJobRunner Map Task Executor \#0\] mapred.MapTask (MapTask.java:flush(1456)) \- kvstart = 26214396(104857584); kvend = 26213684(104854736); length = 713/6553600  
    
32. 2014\-12\-16 15:34:04,179 INFO \[LocalJobRunner Map Task Executor \#0\] mapred.MapTask (MapTask.java:sortAndSpill(1639)) \- Finished spill 0  
    
33. 2014\-12\-16 15:34:04,194 INFO \[LocalJobRunner Map Task Executor \#0\] mapred.Task (Task.java:done(995)) \- Task:attempt\_local1764589720\_0001\_m\_000000\_0 is done. And is in the process of committing  
    
34. 2014\-12\-16 15:34:04,207 INFO \[LocalJobRunner Map Task Executor \#0\] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(591)) \- map  
    
35. 2014\-12\-16 15:34:04,208 INFO \[LocalJobRunner Map Task Executor \#0\] mapred.Task (Task.java:sendDone(1115)) \- Task \\'attempt\_local1764589720\_0001\_m\_000000\_0\\' done.  
    
36. 2014\-12\-16 15:34:04,208 INFO \[LocalJobRunner Map Task Executor \#0\] mapred.LocalJobRunner (LocalJobRunner.java:run(249)) \- Finishing task: attempt\_local1764589720\_0001\_m\_000000\_0  
    
37. 2014\-12\-16 15:34:04,208 INFO \[Thread\-4\] mapred.LocalJobRunner (LocalJobRunner.java:runTasks(456)) \- map task executor complete.  
    
38. 2014\-12\-16 15:34:04,211 INFO \[Thread\-4\] mapred.LocalJobRunner (LocalJobRunner.java:runTasks(448)) \- Waiting for reduce tasks  
    
39. 2014\-12\-16 15:34:04,211 INFO \[pool\-6\-thread\-1\] mapred.LocalJobRunner (LocalJobRunner.java:run(302)) \- Starting task: attempt\_local1764589720\_0001\_r\_000000\_0  
    
40. 2014\-12\-16 15:34:04,221 INFO \[pool\-6\-thread\-1\] util.ProcfsBasedProcessTree (ProcfsBasedProcessTree.java:isAvailable(129)) \- ProcfsBasedProcessTree currently is supported only on Linux.  
    
41. 2014\-12\-16 15:34:04,478 INFO \[pool\-6\-thread\-1\] mapred.Task (Task.java:initialize(581)) \- Using ResourceCalculatorProcessTree : org.apache.hadoop.yarn.util.WindowsBasedProcessTree@36154615  
    
42. 2014\-12\-16 15:34:04,483 INFO \[pool\-6\-thread\-1\] mapred.ReduceTask (ReduceTask.java:run(362)) \- Using ShuffleConsumerPlugin: org.apache.hadoop.mapreduce.task.reduce.Shuffle@e2b02a3  
    
43. 2014\-12\-16 15:34:04,500 INFO \[pool\-6\-thread\-1\] reduce.MergeManagerImpl (MergeManagerImpl.java:<init>(193)) \- MergerManager: memoryLimit=949983616, maxSingleShuffleLimit=237495904, mergeThreshold=626989184, ioSortFactor=10, memToMemMergeOutputsThreshold=10  
    
44. 2014\-12\-16 15:34:04,503 INFO \[EventFetcher for fetching Map Completion Events\] reduce.EventFetcher (EventFetcher.java:run(61)) \- attempt\_local1764589720\_0001\_r\_000000\_0 Thread started: EventFetcher for fetching Map Completion Events  
    
45. 2014\-12\-16 15:34:04,543 INFO \[localfetcher\#1\] reduce.LocalFetcher (LocalFetcher.java:copyMapOutput(140)) \- localfetcher\#1 about to shuffle output of map attempt\_local1764589720\_0001\_m\_000000\_0 decomp: 1832 len: 1836 to MEMORY  
    
46. 2014\-12\-16 15:34:04,548 INFO \[localfetcher\#1\] reduce.InMemoryMapOutput (InMemoryMapOutput.java:shuffle(100)) \- Read 1832 bytes from map\-output for attempt\_local1764589720\_0001\_m\_000000\_0  
    
47. 2014\-12\-16 15:34:04,553 INFO \[localfetcher\#1\] reduce.MergeManagerImpl (MergeManagerImpl.java:closeInMemoryFile(307)) \- closeInMemoryFile \-> map\-output of size: 1832, inMemoryMapOutputs.size() \-> 1, commitMemory \-> 0, usedMemory \->1832  
    
48. 2014\-12\-16 15:34:04,564 INFO \[EventFetcher for fetching Map Completion Events\] reduce.EventFetcher (EventFetcher.java:run(76)) \- EventFetcher is interrupted.. Returning  
    
49. 2014\-12\-16 15:34:04,566 INFO \[pool\-6\-thread\-1\] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(591)) \- 1 / 1 copied.  
    
50. 2014\-12\-16 15:34:04,566 INFO \[pool\-6\-thread\-1\] reduce.MergeManagerImpl (MergeManagerImpl.java:finalMerge(667)) \- finalMerge called with 1 in\-memory map\-outputs and 0 on\-disk map\-outputs  
    
51. 2014\-12\-16 15:34:04,585 INFO \[pool\-6\-thread\-1\] mapred.Merger (Merger.java:merge(589)) \- Merging 1 sorted segments  
    
52. 2014\-12\-16 15:34:04,585 INFO \[pool\-6\-thread\-1\] mapred.Merger (Merger.java:merge(688)) \- Down to the last merge\-pass, with 1 segments left of total size: 1823 bytes  
    
53. 2014\-12\-16 15:34:04,605 INFO \[pool\-6\-thread\-1\] reduce.MergeManagerImpl (MergeManagerImpl.java:finalMerge(742)) \- Merged 1 segments, 1832 bytes to disk to satisfy reduce memory limit  
    
54. 2014\-12\-16 15:34:04,605 INFO \[pool\-6\-thread\-1\] reduce.MergeManagerImpl (MergeManagerImpl.java:finalMerge(772)) \- Merging 1 files, 1836 bytes from disk  
    
55. 2014\-12\-16 15:34:04,606 INFO \[pool\-6\-thread\-1\] reduce.MergeManagerImpl (MergeManagerImpl.java:finalMerge(787)) \- Merging 0 segments, 0 bytes from memory into reduce  
    
56. 2014\-12\-16 15:34:04,607 INFO \[pool\-6\-thread\-1\] mapred.Merger (Merger.java:merge(589)) \- Merging 1 sorted segments  
    
57. 2014\-12\-16 15:34:04,608 INFO \[pool\-6\-thread\-1\] mapred.Merger (Merger.java:merge(688)) \- Down to the last merge\-pass, with 1 segments left of total size: 1823 bytes  
    
58. 2014\-12\-16 15:34:04,608 INFO \[pool\-6\-thread\-1\] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(591)) \- 1 / 1 copied.  
    
59. 2014\-12\-16 15:34:04,643 INFO \[pool\-6\-thread\-1\] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(996)) \- mapred.skip.on is deprecated. Instead, use mapreduce.job.skiprecords  
    
60. 2014\-12\-16 15:34:04,714 INFO \[main\] mapreduce.Job (Job.java:monitorAndPrintJob(1362)) \- map 100% reduce 0%  
    
61. 2014\-12\-16 15:34:04,842 INFO \[pool\-6\-thread\-1\] mapred.Task (Task.java:done(995)) \- Task:attempt\_local1764589720\_0001\_r\_000000\_0 is done. And is in the process of committing  
    
62. 2014\-12\-16 15:34:04,850 INFO \[pool\-6\-thread\-1\] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(591)) \- 1 / 1 copied.  
    
63. 2014\-12\-16 15:34:04,850 INFO \[pool\-6\-thread\-1\] mapred.Task (Task.java:commit(1156)) \- Task attempt\_local1764589720\_0001\_r\_000000\_0 is allowed to commit now  
    
64. 2014\-12\-16 15:34:04,881 INFO \[pool\-6\-thread\-1\] output.FileOutputCommitter (FileOutputCommitter.java:commitTask(439)) \- Saved output of task \\'attempt\_local1764589720\_0001\_r\_000000\_0\\' to hdfs://192.168.52.128:9000/data/output/\_temporary/0/task\_local1764589720\_0001\_r\_000000  
    
65. 2014\-12\-16 15:34:04,884 INFO \[pool\-6\-thread\-1\] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(591)) \- reduce > reduce  
    
66. 2014\-12\-16 15:34:04,884 INFO \[pool\-6\-thread\-1\] mapred.Task (Task.java:sendDone(1115)) \- Task \\'attempt\_local1764589720\_0001\_r\_000000\_0\\' done.  
    
67. 2014\-12\-16 15:34:04,885 INFO \[pool\-6\-thread\-1\] mapred.LocalJobRunner (LocalJobRunner.java:run(325)) \- Finishing task: attempt\_local1764589720\_0001\_r\_000000\_0  
    
68. 2014\-12\-16 15:34:04,885 INFO \[Thread\-4\] mapred.LocalJobRunner (LocalJobRunner.java:runTasks(456)) \- reduce task executor complete.  
    
69. 2014\-12\-16 15:34:05,714 INFO \[main\] mapreduce.Job (Job.java:monitorAndPrintJob(1362)) \- map 100% reduce 100%  
    
70. 2014\-12\-16 15:34:05,714 INFO \[main\] mapreduce.Job (Job.java:monitorAndPrintJob(1373)) \- Job job\_local1764589720\_0001 completed successfully  
    
71. 2014\-12\-16 15:34:05,733 INFO \[main\] mapreduce.Job (Job.java:monitorAndPrintJob(1380)) \- Counters: 38  
    
72.     File System Counters  
    
73.         FILE: Number of bytes read=34542  
    
74.         FILE: Number of bytes written=470650  
    
75.         FILE: Number of read operations=0  
    
76.         FILE: Number of large read operations=0  
    
77.         FILE: Number of write operations=0  
    
78.         HDFS: Number of bytes read=2732  
    
79.         HDFS: Number of bytes written=1306  
    
80.         HDFS: Number of read operations=15  
    
81.         HDFS: Number of large read operations=0  
    
82.         HDFS: Number of write operations=4  
    
83.     Map\-Reduce Framework  
    
84.         Map input records=31  
    
85.         Map output records=179  
    
86.         Map output bytes=2055  
    
87.         Map output materialized bytes=1836  
    
88.         Input split bytes=113  
    
89.         Combine input records=179  
    
90.         Combine output records=131  
    
91.         Reduce input groups=131  
    
92.         Reduce shuffle bytes=1836  
    
93.         Reduce input records=131  
    
94.         Reduce output records=131  
    
95.         Spilled Records=262  
    
96.         Shuffled Maps =1  
    
97.         Failed Shuffles=0  
    
98.         Merged Map outputs=1  
    
99.         GC time elapsed (ms)=13  
    
100.         CPU time spent (ms)=0  
    
101.         Physical memory (bytes) snapshot=0  
    
102.         Virtual memory (bytes) snapshot=0  
    
103.         Total committed heap usage (bytes)=440664064  
    
104.     Shuffle Errors  
    
105.         BAD\_ID=0  
    
106.         CONNECTION=0  
    
107.         IO\_ERROR=0  
    
108.         WRONG\_LENGTH=0  
    
109.         WRONG\_MAP=0  
    
110.         WRONG\_REDUCE=0  
    
111.     File Input Format Counters   
    
112.         Bytes Read=1366  
    
113.     File Output Format Counters   
    
114.         Bytes Written=1306

[http_download.csdn.net_detail_mchdba_8267181_jar]: http://download.csdn.net/detail/mchdba/8267181%EF%BC%8Cjar
[26230597_1418733214H68z.png]: http://blog.itpub.net/attachment/201412/16/26230597_1418733214H68z.png
[26230597_1418733303mmPw.png]: http://blog.itpub.net/attachment/201412/16/26230597_1418733303mmPw.png
[26230597_1418733346JB29.png]: http://blog.itpub.net/attachment/201412/16/26230597_1418733346JB29.png
[26230597_1418733410HT6q.png]: http://blog.itpub.net/attachment/201412/16/26230597_1418733410HT6q.png
[26230597_1418733500130j.png]: http://blog.itpub.net/attachment/201412/16/26230597_1418733500130j.png
[26230597_14187335478qqi.png]: http://blog.itpub.net/attachment/201412/16/26230597_14187335478qqi.png
[26230597_1418733645Oooo.png]: http://blog.itpub.net/attachment/201412/16/26230597_1418733645Oooo.png
[26230597_1418733743B2yf.png]: http://blog.itpub.net/attachment/201412/16/26230597_1418733743B2yf.png
[26230597_1418733974uMcj.png]: http://blog.itpub.net/attachment/201412/16/26230597_1418733974uMcj.png