wordcount程序执行记录
2014-02-19 23:28
169 查看
1./bin/hdfs dfs –mkdir /input 在hadoop的文件系统上的根目录穿件input文件夹
2.执行下面的命令，得到下面的结果。
3.此时可再次查看hadoop文件系统
---------------------------------------------------------------------------------------------------------------------------------------------------
第二种执行方式：
test1.txt文件内容
kongxianghe
kong
yctc
Hello World
test2.txt文件内容
11
2222
kong
Helloyctc
[root@slave hadoop]# bin/hadoop fs -ls /
Found 2 items
drwxr-xr-x - root supergroup 0 2014-01-02 14:38 /foodir
drwxr-xr-x - root supergroup 0 2014-02-19 23:11 /input
[root@slave hadoop]# bin/hadoop fs -ls /input
[root@slave hadoop]# bin/hadoop fs -put wordcont/*.txt /input
[root@slave hadoop]# bin/hadoop fs -ls /input
Found 2 items
-rw-r--r-- 1 root supergroup 34 2014-02-19 23:40 /input/test1.txt
-rw-r--r-- 1 root supergroup 23 2014-02-19 23:40 /input/test2.txt
[root@slave hadoop]# bin/hadoop fs -cat /input/test1.txt
kongxianghe
kong
yctc
Hello World
[root@slave hadoop]# bin/hadoop jar share/hadoop/mapreduce/hadoop-mapreduce-examples-2.2.0.jar wordcount /input /output
2014-02-19 23:46:39,357 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - session.id is deprecated. Instead, use dfs.metrics.session-id
2014-02-19 23:46:39,361 INFO [main] jvm.JvmMetrics (JvmMetrics.java:init(76)) - Initializing JVM Metrics with processName=JobTracker, sessionId=
2014-02-19 23:46:40,676 INFO [main] input.FileInputFormat (FileInputFormat.java:listStatus(287)) - Total input paths to process : 2
2014-02-19 23:46:40,784 INFO [main] mapreduce.JobSubmitter (JobSubmitter.java:submitJobInternal(394)) - number of splits:2
2014-02-19 23:46:40,848 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - user.name is deprecated. Instead, use mapreduce.job.user.name
2014-02-19 23:46:40,849 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.jar is deprecated. Instead, use mapreduce.job.jar
2014-02-19 23:46:40,851 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.output.value.class is deprecated. Instead, use mapreduce.job.output.value.class
2014-02-19 23:46:40,852 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapreduce.combine.class is deprecated. Instead, use mapreduce.job.combine.class
2014-02-19 23:46:40,852 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapreduce.map.class is deprecated. Instead, use mapreduce.job.map.class
2014-02-19 23:46:40,852 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.job.name is deprecated. Instead, use mapreduce.job.name
2014-02-19 23:46:40,853 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapreduce.reduce.class is deprecated. Instead, use mapreduce.job.reduce.class
2014-02-19 23:46:40,853 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.input.dir is deprecated. Instead, use mapreduce.input.fileinputformat.inputdir
2014-02-19 23:46:40,854 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.output.dir is deprecated. Instead, use mapreduce.output.fileoutputformat.outputdir
2014-02-19 23:46:40,854 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.map.tasks is deprecated. Instead, use mapreduce.job.maps
2014-02-19 23:46:40,855 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.output.key.class is deprecated. Instead, use mapreduce.job.output.key.class
2014-02-19 23:46:40,856 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.working.dir is deprecated. Instead, use mapreduce.job.working.dir
2014-02-19 23:46:42,301 INFO [main] mapreduce.JobSubmitter (JobSubmitter.java:printTokens(477)) - Submitting tokens for job: job_local1764843707_0001
2014-02-19 23:46:42,378 WARN [main] conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/hadoop/tmp/mapred/staging/root1764843707/.staging/job_local1764843707_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2014-02-19 23:46:42,633 WARN [main] conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/hadoop/tmp/mapred/staging/root1764843707/.staging/job_local1764843707_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2014-02-19 23:46:42,978 WARN [main] conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/hadoop/tmp/mapred/local/localRunner/root/job_local1764843707_0001/job_local1764843707_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2014-02-19 23:46:42,978 WARN [main] conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/hadoop/tmp/mapred/local/localRunner/root/job_local1764843707_0001/job_local1764843707_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2014-02-19 23:46:42,985 INFO [main] mapreduce.Job (Job.java:submit(1272)) - The url to track the job: http://localhost:8080/ 2014-02-19 23:46:42,989 INFO [main] mapreduce.Job (Job.java:monitorAndPrintJob(1317)) - Running job: job_local1764843707_0001
2014-02-19 23:46:42,994 INFO [Thread-4] mapred.LocalJobRunner (LocalJobRunner.java:createOutputCommitter(323)) - OutputCommitter set in config null
2014-02-19 23:46:43,070 INFO [Thread-4] mapred.LocalJobRunner (LocalJobRunner.java:createOutputCommitter(341)) - OutputCommitter is org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter
2014-02-19 23:46:43,237 INFO [Thread-4] mapred.LocalJobRunner (LocalJobRunner.java:run(389)) - Waiting for map tasks
2014-02-19 23:46:43,239 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:run(216)) - Starting task: attempt_local1764843707_0001_m_000000_0
2014-02-19 23:46:43,449 INFO [LocalJobRunner Map Task Executor #0] mapred.Task (Task.java:initialize(581)) - Using ResourceCalculatorProcessTree : [ ]
2014-02-19 23:46:43,455 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:runNewMapper(732)) - Processing split: hdfs://master:9000/input/test1.txt:0+34
2014-02-19 23:46:43,483 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:createSortingCollector(387)) - Map output collector class = org.apache.hadoop.mapred.MapTask$MapOutputBuffer
2014-02-19 23:46:43,616 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:setEquator(1183)) - (EQUATOR) 0 kvi 26214396(104857584)
2014-02-19 23:46:43,617 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:init(975)) - mapreduce.task.io.sort.mb: 100
2014-02-19 23:46:43,617 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:init(976)) - soft limit at 83886080
2014-02-19 23:46:43,617 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:init(977)) - bufstart = 0; bufvoid = 104857600
2014-02-19 23:46:43,617 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:init(978)) - kvstart = 26214396; length = 6553600
2014-02-19 23:46:43,721 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) -
2014-02-19 23:46:43,726 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:flush(1440)) - Starting flush of map output
2014-02-19 23:46:43,726 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:flush(1459)) - Spilling map output
2014-02-19 23:46:43,727 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:flush(1460)) - bufstart = 0; bufend = 54; bufvoid = 104857600
2014-02-19 23:46:43,727 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:flush(1462)) - kvstart = 26214396(104857584); kvend = 26214380(104857520); length = 17/6553600
2014-02-19 23:46:43,763 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:sortAndSpill(1648)) - Finished spill 0
2014-02-19 23:46:43,770 INFO [LocalJobRunner Map Task Executor #0] mapred.Task (Task.java:done(995)) - Task:attempt_local1764843707_0001_m_000000_0 is done. And is in the process of committing
2014-02-19 23:46:43,780 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - map
2014-02-19 23:46:43,780 INFO [LocalJobRunner Map Task Executor #0] mapred.Task (Task.java:sendDone(1115)) - Task 'attempt_local1764843707_0001_m_000000_0' done.
2014-02-19 23:46:43,781 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:run(241)) - Finishing task: attempt_local1764843707_0001_m_000000_0
2014-02-19 23:46:43,781 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:run(216)) - Starting task: attempt_local1764843707_0001_m_000001_0
2014-02-19 23:46:43,790 INFO [LocalJobRunner Map Task Executor #0] mapred.Task (Task.java:initialize(581)) - Using ResourceCalculatorProcessTree : [ ]
2014-02-19 23:46:43,792 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:runNewMapper(732)) - Processing split: hdfs://master:9000/input/test2.txt:0+23
2014-02-19 23:46:43,793 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:createSortingCollector(387)) - Map output collector class = org.apache.hadoop.mapred.MapTask$MapOutputBuffer
2014-02-19 23:46:43,857 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:setEquator(1183)) - (EQUATOR) 0 kvi 26214396(104857584)
2014-02-19 23:46:43,857 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:init(975)) - mapreduce.task.io.sort.mb: 100
2014-02-19 23:46:43,857 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:init(976)) - soft limit at 83886080
2014-02-19 23:46:43,857 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:init(977)) - bufstart = 0; bufvoid = 104857600
2014-02-19 23:46:43,857 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:init(978)) - kvstart = 26214396; length = 6553600
2014-02-19 23:46:43,864 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) -
2014-02-19 23:46:43,864 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:flush(1440)) - Starting flush of map output
2014-02-19 23:46:43,865 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:flush(1459)) - Spilling map output
2014-02-19 23:46:43,865 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:flush(1460)) - bufstart = 0; bufend = 39; bufvoid = 104857600
2014-02-19 23:46:43,865 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:flush(1462)) - kvstart = 26214396(104857584); kvend = 26214384(104857536); length = 13/6553600
2014-02-19 23:46:43,869 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:sortAndSpill(1648)) - Finished spill 0
2014-02-19 23:46:43,871 INFO [LocalJobRunner Map Task Executor #0] mapred.Task (Task.java:done(995)) - Task:attempt_local1764843707_0001_m_000001_0 is done. And is in the process of committing
2014-02-19 23:46:43,875 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - map
2014-02-19 23:46:43,875 INFO [LocalJobRunner Map Task Executor #0] mapred.Task (Task.java:sendDone(1115)) - Task 'attempt_local1764843707_0001_m_000001_0' done.
2014-02-19 23:46:43,875 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:run(241)) - Finishing task: attempt_local1764843707_0001_m_000001_0
2014-02-19 23:46:43,876 INFO [Thread-4] mapred.LocalJobRunner (LocalJobRunner.java:run(397)) - Map task executor complete.
2014-02-19 23:46:43,918 INFO [Thread-4] mapred.Task (Task.java:initialize(581)) - Using ResourceCalculatorProcessTree : [ ]
2014-02-19 23:46:43,926 INFO [Thread-4] mapred.Merger (Merger.java:merge(568)) - Merging 2 sorted segments
2014-02-19 23:46:43,992 INFO [Thread-4] mapred.Merger (Merger.java:merge(667)) - Down to the last merge-pass, with 2 segments left of total size: 102 bytes
2014-02-19 23:46:43,993 INFO [Thread-4] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) -
2014-02-19 23:46:44,002 INFO [main] mapreduce.Job (Job.java:monitorAndPrintJob(1338)) - Job job_local1764843707_0001 running in uber mode : false
2014-02-19 23:46:44,023 INFO [Thread-4] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.skip.on is deprecated. Instead, use mapreduce.job.skiprecords
2014-02-19 23:46:44,043 INFO [main] mapreduce.Job (Job.java:monitorAndPrintJob(1345)) - map 100% reduce 0%
2014-02-19 23:46:44,135 INFO [Thread-4] mapred.Task (Task.java:done(995)) - Task:attempt_local1764843707_0001_r_000000_0 is done. And is in the process of committing
2014-02-19 23:46:44,138 INFO [Thread-4] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) -
2014-02-19 23:46:44,138 INFO [Thread-4] mapred.Task (Task.java:commit(1156)) - Task attempt_local1764843707_0001_r_000000_0 is allowed to commit now
2014-02-19 23:46:44,148 INFO [Thread-4] output.FileOutputCommitter (FileOutputCommitter.java:commitTask(439)) - Saved output of task 'attempt_local1764843707_0001_r_000000_0' to hdfs://master:9000/output/_temporary/0/task_local1764843707_0001_r_000000
2014-02-19 23:46:44,149 INFO [Thread-4] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - reduce > reduce
2014-02-19 23:46:44,149 INFO [Thread-4] mapred.Task (Task.java:sendDone(1115)) - Task 'attempt_local1764843707_0001_r_000000_0' done.
2014-02-19 23:46:45,050 INFO [main] mapreduce.Job (Job.java:monitorAndPrintJob(1345)) - map 100% reduce 100%
2014-02-19 23:46:45,052 INFO [main] mapreduce.Job (Job.java:monitorAndPrintJob(1356)) - Job job_local1764843707_0001 completed successfully
2014-02-19 23:46:45,107 INFO [main] mapreduce.Job (Job.java:monitorAndPrintJob(1363)) - Counters: 32
File System Counters
FILE: Number of bytes read=812009
FILE: Number of bytes written=1371545
FILE: Number of read operations=0
FILE: Number of large read operations=0
FILE: Number of write operations=0
HDFS: Number of bytes read=148
HDFS: Number of bytes written=68
HDFS: Number of read operations=25
HDFS: Number of large read operations=0
HDFS: Number of write operations=5
Map-Reduce Framework
Map input records=8
Map output records=9
Map output bytes=93
Map output materialized bytes=123
Input split bytes=198
Combine input records=9
Combine output records=9
Reduce input groups=8
Reduce shuffle bytes=0
Reduce input records=9
Reduce output records=8
Spilled Records=18
Shuffled Maps =0
Failed Shuffles=0
Merged Map outputs=0
GC time elapsed (ms)=100
CPU time spent (ms)=0
Physical memory (bytes) snapshot=0
Virtual memory (bytes) snapshot=0
Total committed heap usage (bytes)=456732672
File Input Format Counters
Bytes Read=57
File Output Format Counters
Bytes Written=68
[root@slave hadoop]# bin/hadoop fs -ls /input
Found 2 items
-rw-r--r-- 1 root supergroup 34 2014-02-19 23:40 /input/test1.txt
-rw-r--r-- 1 root supergroup 23 2014-02-19 23:40 /input/test2.txt
[root@slave hadoop]# bin/hadoop fs -ls /
Found 3 items
drwxr-xr-x - root supergroup 0 2014-01-02 14:38 /foodir
drwxr-xr-x - root supergroup 0 2014-02-19 23:40 /input
drwxr-xr-x - root supergroup 0 2014-02-19 23:44 /output
[root@slave hadoop]# bin/hadoop fs -ls /output
Found 2 items
-rw-r--r-- 1 root supergroup 0 2014-02-19 23:44 /output/_SUCCESS
-rw-r--r-- 1 root supergroup 68 2014-02-19 23:44 /output/part-r-00000
[root@slave hadoop]# bin/hadoop fs -cat /output/part-r-00000
11 1
2222 1
Hello 1
Helloyctc 1
World 1
kong 2
kongxianghe 1
yctc 1
[root@slave hadoop]#
2.执行下面的命令，得到下面的结果。
[root@slave hadoop]# bin/hadoop jar share/hadoop/mapreduce/hadoop-mapreduce-examples-2.2.0.jar randomwriter input 2014-02-19 23:23:43,096 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - session.id is deprecated. Instead, use dfs.metrics.session-id 2014-02-19 23:23:43,101 INFO [main] jvm.JvmMetrics (JvmMetrics.java:init(76)) - Initializing JVM Metrics with processName=JobTracker, sessionId= Running 10 maps. Job started: Wed Feb 19 23:23:43 CST 2014 2014-02-19 23:23:43,640 INFO [main] jvm.JvmMetrics (JvmMetrics.java:init(71)) - Cannot initialize JVM Metrics with processName=JobTracker, sessionId= - already initialized 2014-02-19 23:23:45,139 INFO [main] mapreduce.JobSubmitter (JobSubmitter.java:submitJobInternal(394)) - number of splits:1 2014-02-19 23:23:45,190 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - user.name is deprecated. Instead, use mapreduce.job.user.name 2014-02-19 23:23:45,191 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.jar is deprecated. Instead, use mapreduce.job.jar 2014-02-19 23:23:45,192 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.reduce.tasks is deprecated. Instead, use mapreduce.job.reduces 2014-02-19 23:23:45,192 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.output.value.class is deprecated. Instead, use mapreduce.job.output.value.class 2014-02-19 23:23:45,193 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapreduce.map.class is deprecated. Instead, use mapreduce.job.map.class 2014-02-19 23:23:45,194 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.job.name is deprecated. Instead, use mapreduce.job.name 2014-02-19 23:23:45,194 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapreduce.reduce.class is deprecated. Instead, use mapreduce.job.reduce.class 2014-02-19 23:23:45,194 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapreduce.inputformat.class is deprecated. Instead, use mapreduce.job.inputformat.class 2014-02-19 23:23:45,195 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.output.dir is deprecated. Instead, use mapreduce.output.fileoutputformat.outputdir 2014-02-19 23:23:45,195 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapreduce.outputformat.class is deprecated. Instead, use mapreduce.job.outputformat.class 2014-02-19 23:23:45,195 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.map.tasks is deprecated. Instead, use mapreduce.job.maps 2014-02-19 23:23:45,196 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.output.key.class is deprecated. Instead, use mapreduce.job.output.key.class 2014-02-19 23:23:45,202 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.working.dir is deprecated. Instead, use mapreduce.job.working.dir 2014-02-19 23:23:46,043 INFO [main] mapreduce.JobSubmitter (JobSubmitter.java:printTokens(477)) - Submitting tokens for job: job_local376256255_0001 2014-02-19 23:23:46,522 WARN [main] conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/hadoop/tmp/mapred/staging/root376256255/.staging/job_local376256255_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring. 2014-02-19 23:23:46,562 WARN [main] conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/hadoop/tmp/mapred/staging/root376256255/.staging/job_local376256255_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring. 2014-02-19 23:23:46,889 WARN [main] conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/hadoop/tmp/mapred/local/localRunner/root/job_local376256255_0001/job_local376256255_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring. 2014-02-19 23:23:46,890 WARN [main] conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/hadoop/tmp/mapred/local/localRunner/root/job_local376256255_0001/job_local376256255_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring. 2014-02-19 23:23:46,897 INFO [main] mapreduce.Job (Job.java:submit(1272)) - The url to track the job: http://localhost:8080/ 2014-02-19 23:23:46,898 INFO [main] mapreduce.Job (Job.java:monitorAndPrintJob(1317)) - Running job: job_local376256255_0001 2014-02-19 23:23:46,939 INFO [Thread-4] mapred.LocalJobRunner (LocalJobRunner.java:createOutputCommitter(323)) - OutputCommitter set in config null 2014-02-19 23:23:46,968 INFO [Thread-4] mapred.LocalJobRunner (LocalJobRunner.java:createOutputCommitter(341)) - OutputCommitter is org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter 2014-02-19 23:23:47,157 INFO [Thread-4] mapred.LocalJobRunner (LocalJobRunner.java:run(389)) - Waiting for map tasks 2014-02-19 23:23:47,158 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:run(216)) - Starting task: attempt_local376256255_0001_m_000000_0 2014-02-19 23:23:47,426 INFO [LocalJobRunner Map Task Executor #0] mapred.Task (Task.java:initialize(581)) - Using ResourceCalculatorProcessTree : [ ] 2014-02-19 23:23:47,434 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:runNewMapper(732)) - Processing split: hdfs://master:9000/user/root/input/dummy-split-0:0+1 2014-02-19 23:23:47,905 INFO [main] mapreduce.Job (Job.java:monitorAndPrintJob(1338)) - Job job_local376256255_0001 running in uber mode : false 2014-02-19 23:23:48,017 INFO [main] mapreduce.Job (Job.java:monitorAndPrintJob(1345)) - map 0% reduce 0% 2014-02-19 23:24:02,434 INFO [communication thread] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - wrote record 13400. 933063877 bytes left. > map 2014-02-19 23:24:05,437 INFO [communication thread] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - wrote record 26000. 800259916 bytes left. > map 2014-02-19 23:24:08,441 INFO [communication thread] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - wrote record 34000. 715683510 bytes left. > map 2014-02-19 23:24:11,446 INFO [communication thread] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - wrote record 34000. 715683510 bytes left. > map 2014-02-19 23:24:24,926 INFO [communication thread] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - wrote record 42600. 624959477 bytes left. > map 2014-02-19 23:24:27,929 INFO [communication thread] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - wrote record 45200. 598029247 bytes left. > map 2014-02-19 23:24:38,648 INFO [communication thread] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - wrote record 45400. 596061464 bytes left. > map 2014-02-19 23:24:41,651 INFO [communication thread] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - wrote record 51000. 537167506 bytes left. > map 2014-02-19 23:24:44,655 INFO [communication thread] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - wrote record 57000. 474179605 bytes left. > map 2014-02-19 23:24:47,658 INFO [communication thread] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - wrote record 64000. 399456326 bytes left. > map 2014-02-19 23:24:50,662 INFO [communication thread] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - wrote record 70800. 327545729 bytes left. > map 2014-02-19 23:24:54,113 INFO [communication thread] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - wrote record 70800. 327545729 bytes left. > map 2014-02-19 23:25:06,121 INFO [communication thread] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - wrote record 74400. 289497517 bytes left. > map 2014-02-19 23:25:15,383 INFO [communication thread] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - wrote record 91800. 106171073 bytes left. > map 2014-02-19 23:25:18,385 INFO [communication thread] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - wrote record 91800. 106171073 bytes left. > map 2014-02-19 23:25:31,308 INFO [communication thread] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - wrote record 98000. 41512843 bytes left. > map 2014-02-19 23:25:36,087 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - wrote record 98000. 41512843 bytes left. > map 2014-02-19 23:25:40,316 INFO [communication thread] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - done with 101931 records. 2014-02-19 23:25:40,350 INFO [main] mapreduce.Job (Job.java:monitorAndPrintJob(1345)) - map 100% reduce 0% 2014-02-19 23:25:43,319 INFO [communication thread] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - done with 101931 records. 2014-02-19 23:25:44,336 INFO [LocalJobRunner Map Task Executor #0] mapred.Task (Task.java:done(995)) - Task:attempt_local376256255_0001_m_000000_0 is done. And is in the process of committing 2014-02-19 23:25:44,340 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - done with 101931 records. 2014-02-19 23:25:44,340 INFO [LocalJobRunner Map Task Executor #0] mapred.Task (Task.java:commit(1156)) - Task attempt_local376256255_0001_m_000000_0 is allowed to commit now 2014-02-19 23:25:45,307 INFO [LocalJobRunner Map Task Executor #0] output.FileOutputCommitter (FileOutputCommitter.java:commitTask(439)) - Saved output of task 'attempt_local376256255_0001_m_000000_0' to hdfs://master:9000/user/root/input/_temporary/0/task_local376256255_0001_m_000000 2014-02-19 23:25:45,310 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - done with 101931 records. 2014-02-19 23:25:45,311 INFO [LocalJobRunner Map Task Executor #0] mapred.Task (Task.java:sendDone(1115)) - Task 'attempt_local376256255_0001_m_000000_0' done. 2014-02-19 23:25:45,312 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:run(241)) - Finishing task: attempt_local376256255_0001_m_000000_0 2014-02-19 23:25:45,313 INFO [Thread-4] mapred.LocalJobRunner (LocalJobRunner.java:run(397)) - Map task executor complete. 2014-02-19 23:25:46,366 INFO [main] mapreduce.Job (Job.java:monitorAndPrintJob(1356)) - Job job_local376256255_0001 completed successfully 2014-02-19 23:25:46,999 INFO [main] mapreduce.Job (Job.java:monitorAndPrintJob(1363)) - Counters: 25 File System Counters FILE: Number of bytes read=270384 FILE: Number of bytes written=455600 FILE: Number of read operations=0 FILE: Number of large read operations=0 FILE: Number of write operations=0 HDFS: Number of bytes read=0 HDFS: Number of bytes written=1077273165 HDFS: Number of read operations=4 HDFS: Number of large read operations=0 HDFS: Number of write operations=3 Map-Reduce Framework Map input records=1 Map output records=101931 Input split bytes=113 Spilled Records=0 Failed Shuffles=0 Merged Map outputs=0 GC time elapsed (ms)=12069 CPU time spent (ms)=0 Physical memory (bytes) snapshot=0 Virtual memory (bytes) snapshot=0 Total committed heap usage (bytes)=26218496 org.apache.hadoop.examples.RandomWriter$Counters BYTES_WRITTEN=1073743693 RECORDS_WRITTEN=101931 File Input Format Counters Bytes Read=0 File Output Format Counters Bytes Written=1077273165 Job ended: Wed Feb 19 23:25:46 CST 2014 The job took 123 seconds. [root@slave hadoop]#
3.此时可再次查看hadoop文件系统
[root@slave hadoop]# bin/hadoop fs -ls / Found 3 items drwxr-xr-x - root supergroup 0 2014-01-02 14:38 /foodir drwxr-xr-x - root supergroup 0 2014-02-19 23:11 /input drwxr-xr-x - root supergroup 0 2014-02-19 23:21 /user [root@slave hadoop]# bin/hadoop fs -ls /user Found 1 items drwxr-xr-x - root supergroup 0 2014-02-19 23:21 /user/root [root@slave hadoop]# bin/hadoop fs -ls /user/root Found 1 items drwxr-xr-x - root supergroup 0 2014-02-19 23:23 /user/root/input [root@slave hadoop]# bin/hadoop fs -ls /user/root/input Found 2 items -rw-r--r-- 1 root supergroup 0 2014-02-19 23:23 /user/root/input/_SUCCESS -rw-r--r-- 1 root supergroup 1077273165 2014-02-19 23:23 /user/root/input/part-m-00000 [root@slave hadoop]#
---------------------------------------------------------------------------------------------------------------------------------------------------
第二种执行方式：
test1.txt文件内容
kongxianghe
kong
yctc
Hello World
test2.txt文件内容
11
2222
kong
Helloyctc
[root@slave hadoop]# bin/hadoop fs -ls /
Found 2 items
drwxr-xr-x - root supergroup 0 2014-01-02 14:38 /foodir
drwxr-xr-x - root supergroup 0 2014-02-19 23:11 /input
[root@slave hadoop]# bin/hadoop fs -ls /input
[root@slave hadoop]# bin/hadoop fs -put wordcont/*.txt /input
[root@slave hadoop]# bin/hadoop fs -ls /input
Found 2 items
-rw-r--r-- 1 root supergroup 34 2014-02-19 23:40 /input/test1.txt
-rw-r--r-- 1 root supergroup 23 2014-02-19 23:40 /input/test2.txt
[root@slave hadoop]# bin/hadoop fs -cat /input/test1.txt
kongxianghe
kong
yctc
Hello World
[root@slave hadoop]# bin/hadoop jar share/hadoop/mapreduce/hadoop-mapreduce-examples-2.2.0.jar wordcount /input /output
2014-02-19 23:46:39,357 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - session.id is deprecated. Instead, use dfs.metrics.session-id
2014-02-19 23:46:39,361 INFO [main] jvm.JvmMetrics (JvmMetrics.java:init(76)) - Initializing JVM Metrics with processName=JobTracker, sessionId=
2014-02-19 23:46:40,676 INFO [main] input.FileInputFormat (FileInputFormat.java:listStatus(287)) - Total input paths to process : 2
2014-02-19 23:46:40,784 INFO [main] mapreduce.JobSubmitter (JobSubmitter.java:submitJobInternal(394)) - number of splits:2
2014-02-19 23:46:40,848 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - user.name is deprecated. Instead, use mapreduce.job.user.name
2014-02-19 23:46:40,849 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.jar is deprecated. Instead, use mapreduce.job.jar
2014-02-19 23:46:40,851 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.output.value.class is deprecated. Instead, use mapreduce.job.output.value.class
2014-02-19 23:46:40,852 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapreduce.combine.class is deprecated. Instead, use mapreduce.job.combine.class
2014-02-19 23:46:40,852 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapreduce.map.class is deprecated. Instead, use mapreduce.job.map.class
2014-02-19 23:46:40,852 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.job.name is deprecated. Instead, use mapreduce.job.name
2014-02-19 23:46:40,853 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapreduce.reduce.class is deprecated. Instead, use mapreduce.job.reduce.class
2014-02-19 23:46:40,853 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.input.dir is deprecated. Instead, use mapreduce.input.fileinputformat.inputdir
2014-02-19 23:46:40,854 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.output.dir is deprecated. Instead, use mapreduce.output.fileoutputformat.outputdir
2014-02-19 23:46:40,854 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.map.tasks is deprecated. Instead, use mapreduce.job.maps
2014-02-19 23:46:40,855 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.output.key.class is deprecated. Instead, use mapreduce.job.output.key.class
2014-02-19 23:46:40,856 INFO [main] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.working.dir is deprecated. Instead, use mapreduce.job.working.dir
2014-02-19 23:46:42,301 INFO [main] mapreduce.JobSubmitter (JobSubmitter.java:printTokens(477)) - Submitting tokens for job: job_local1764843707_0001
2014-02-19 23:46:42,378 WARN [main] conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/hadoop/tmp/mapred/staging/root1764843707/.staging/job_local1764843707_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2014-02-19 23:46:42,633 WARN [main] conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/hadoop/tmp/mapred/staging/root1764843707/.staging/job_local1764843707_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2014-02-19 23:46:42,978 WARN [main] conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/hadoop/tmp/mapred/local/localRunner/root/job_local1764843707_0001/job_local1764843707_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2014-02-19 23:46:42,978 WARN [main] conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/hadoop/tmp/mapred/local/localRunner/root/job_local1764843707_0001/job_local1764843707_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2014-02-19 23:46:42,985 INFO [main] mapreduce.Job (Job.java:submit(1272)) - The url to track the job: http://localhost:8080/ 2014-02-19 23:46:42,989 INFO [main] mapreduce.Job (Job.java:monitorAndPrintJob(1317)) - Running job: job_local1764843707_0001
2014-02-19 23:46:42,994 INFO [Thread-4] mapred.LocalJobRunner (LocalJobRunner.java:createOutputCommitter(323)) - OutputCommitter set in config null
2014-02-19 23:46:43,070 INFO [Thread-4] mapred.LocalJobRunner (LocalJobRunner.java:createOutputCommitter(341)) - OutputCommitter is org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter
2014-02-19 23:46:43,237 INFO [Thread-4] mapred.LocalJobRunner (LocalJobRunner.java:run(389)) - Waiting for map tasks
2014-02-19 23:46:43,239 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:run(216)) - Starting task: attempt_local1764843707_0001_m_000000_0
2014-02-19 23:46:43,449 INFO [LocalJobRunner Map Task Executor #0] mapred.Task (Task.java:initialize(581)) - Using ResourceCalculatorProcessTree : [ ]
2014-02-19 23:46:43,455 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:runNewMapper(732)) - Processing split: hdfs://master:9000/input/test1.txt:0+34
2014-02-19 23:46:43,483 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:createSortingCollector(387)) - Map output collector class = org.apache.hadoop.mapred.MapTask$MapOutputBuffer
2014-02-19 23:46:43,616 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:setEquator(1183)) - (EQUATOR) 0 kvi 26214396(104857584)
2014-02-19 23:46:43,617 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:init(975)) - mapreduce.task.io.sort.mb: 100
2014-02-19 23:46:43,617 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:init(976)) - soft limit at 83886080
2014-02-19 23:46:43,617 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:init(977)) - bufstart = 0; bufvoid = 104857600
2014-02-19 23:46:43,617 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:init(978)) - kvstart = 26214396; length = 6553600
2014-02-19 23:46:43,721 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) -
2014-02-19 23:46:43,726 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:flush(1440)) - Starting flush of map output
2014-02-19 23:46:43,726 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:flush(1459)) - Spilling map output
2014-02-19 23:46:43,727 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:flush(1460)) - bufstart = 0; bufend = 54; bufvoid = 104857600
2014-02-19 23:46:43,727 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:flush(1462)) - kvstart = 26214396(104857584); kvend = 26214380(104857520); length = 17/6553600
2014-02-19 23:46:43,763 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:sortAndSpill(1648)) - Finished spill 0
2014-02-19 23:46:43,770 INFO [LocalJobRunner Map Task Executor #0] mapred.Task (Task.java:done(995)) - Task:attempt_local1764843707_0001_m_000000_0 is done. And is in the process of committing
2014-02-19 23:46:43,780 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - map
2014-02-19 23:46:43,780 INFO [LocalJobRunner Map Task Executor #0] mapred.Task (Task.java:sendDone(1115)) - Task 'attempt_local1764843707_0001_m_000000_0' done.
2014-02-19 23:46:43,781 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:run(241)) - Finishing task: attempt_local1764843707_0001_m_000000_0
2014-02-19 23:46:43,781 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:run(216)) - Starting task: attempt_local1764843707_0001_m_000001_0
2014-02-19 23:46:43,790 INFO [LocalJobRunner Map Task Executor #0] mapred.Task (Task.java:initialize(581)) - Using ResourceCalculatorProcessTree : [ ]
2014-02-19 23:46:43,792 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:runNewMapper(732)) - Processing split: hdfs://master:9000/input/test2.txt:0+23
2014-02-19 23:46:43,793 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:createSortingCollector(387)) - Map output collector class = org.apache.hadoop.mapred.MapTask$MapOutputBuffer
2014-02-19 23:46:43,857 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:setEquator(1183)) - (EQUATOR) 0 kvi 26214396(104857584)
2014-02-19 23:46:43,857 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:init(975)) - mapreduce.task.io.sort.mb: 100
2014-02-19 23:46:43,857 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:init(976)) - soft limit at 83886080
2014-02-19 23:46:43,857 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:init(977)) - bufstart = 0; bufvoid = 104857600
2014-02-19 23:46:43,857 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:init(978)) - kvstart = 26214396; length = 6553600
2014-02-19 23:46:43,864 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) -
2014-02-19 23:46:43,864 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:flush(1440)) - Starting flush of map output
2014-02-19 23:46:43,865 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:flush(1459)) - Spilling map output
2014-02-19 23:46:43,865 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:flush(1460)) - bufstart = 0; bufend = 39; bufvoid = 104857600
2014-02-19 23:46:43,865 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:flush(1462)) - kvstart = 26214396(104857584); kvend = 26214384(104857536); length = 13/6553600
2014-02-19 23:46:43,869 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:sortAndSpill(1648)) - Finished spill 0
2014-02-19 23:46:43,871 INFO [LocalJobRunner Map Task Executor #0] mapred.Task (Task.java:done(995)) - Task:attempt_local1764843707_0001_m_000001_0 is done. And is in the process of committing
2014-02-19 23:46:43,875 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - map
2014-02-19 23:46:43,875 INFO [LocalJobRunner Map Task Executor #0] mapred.Task (Task.java:sendDone(1115)) - Task 'attempt_local1764843707_0001_m_000001_0' done.
2014-02-19 23:46:43,875 INFO [LocalJobRunner Map Task Executor #0] mapred.LocalJobRunner (LocalJobRunner.java:run(241)) - Finishing task: attempt_local1764843707_0001_m_000001_0
2014-02-19 23:46:43,876 INFO [Thread-4] mapred.LocalJobRunner (LocalJobRunner.java:run(397)) - Map task executor complete.
2014-02-19 23:46:43,918 INFO [Thread-4] mapred.Task (Task.java:initialize(581)) - Using ResourceCalculatorProcessTree : [ ]
2014-02-19 23:46:43,926 INFO [Thread-4] mapred.Merger (Merger.java:merge(568)) - Merging 2 sorted segments
2014-02-19 23:46:43,992 INFO [Thread-4] mapred.Merger (Merger.java:merge(667)) - Down to the last merge-pass, with 2 segments left of total size: 102 bytes
2014-02-19 23:46:43,993 INFO [Thread-4] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) -
2014-02-19 23:46:44,002 INFO [main] mapreduce.Job (Job.java:monitorAndPrintJob(1338)) - Job job_local1764843707_0001 running in uber mode : false
2014-02-19 23:46:44,023 INFO [Thread-4] Configuration.deprecation (Configuration.java:warnOnceIfDeprecated(840)) - mapred.skip.on is deprecated. Instead, use mapreduce.job.skiprecords
2014-02-19 23:46:44,043 INFO [main] mapreduce.Job (Job.java:monitorAndPrintJob(1345)) - map 100% reduce 0%
2014-02-19 23:46:44,135 INFO [Thread-4] mapred.Task (Task.java:done(995)) - Task:attempt_local1764843707_0001_r_000000_0 is done. And is in the process of committing
2014-02-19 23:46:44,138 INFO [Thread-4] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) -
2014-02-19 23:46:44,138 INFO [Thread-4] mapred.Task (Task.java:commit(1156)) - Task attempt_local1764843707_0001_r_000000_0 is allowed to commit now
2014-02-19 23:46:44,148 INFO [Thread-4] output.FileOutputCommitter (FileOutputCommitter.java:commitTask(439)) - Saved output of task 'attempt_local1764843707_0001_r_000000_0' to hdfs://master:9000/output/_temporary/0/task_local1764843707_0001_r_000000
2014-02-19 23:46:44,149 INFO [Thread-4] mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(513)) - reduce > reduce
2014-02-19 23:46:44,149 INFO [Thread-4] mapred.Task (Task.java:sendDone(1115)) - Task 'attempt_local1764843707_0001_r_000000_0' done.
2014-02-19 23:46:45,050 INFO [main] mapreduce.Job (Job.java:monitorAndPrintJob(1345)) - map 100% reduce 100%
2014-02-19 23:46:45,052 INFO [main] mapreduce.Job (Job.java:monitorAndPrintJob(1356)) - Job job_local1764843707_0001 completed successfully
2014-02-19 23:46:45,107 INFO [main] mapreduce.Job (Job.java:monitorAndPrintJob(1363)) - Counters: 32
File System Counters
FILE: Number of bytes read=812009
FILE: Number of bytes written=1371545
FILE: Number of read operations=0
FILE: Number of large read operations=0
FILE: Number of write operations=0
HDFS: Number of bytes read=148
HDFS: Number of bytes written=68
HDFS: Number of read operations=25
HDFS: Number of large read operations=0
HDFS: Number of write operations=5
Map-Reduce Framework
Map input records=8
Map output records=9
Map output bytes=93
Map output materialized bytes=123
Input split bytes=198
Combine input records=9
Combine output records=9
Reduce input groups=8
Reduce shuffle bytes=0
Reduce input records=9
Reduce output records=8
Spilled Records=18
Shuffled Maps =0
Failed Shuffles=0
Merged Map outputs=0
GC time elapsed (ms)=100
CPU time spent (ms)=0
Physical memory (bytes) snapshot=0
Virtual memory (bytes) snapshot=0
Total committed heap usage (bytes)=456732672
File Input Format Counters
Bytes Read=57
File Output Format Counters
Bytes Written=68
[root@slave hadoop]# bin/hadoop fs -ls /input
Found 2 items
-rw-r--r-- 1 root supergroup 34 2014-02-19 23:40 /input/test1.txt
-rw-r--r-- 1 root supergroup 23 2014-02-19 23:40 /input/test2.txt
[root@slave hadoop]# bin/hadoop fs -ls /
Found 3 items
drwxr-xr-x - root supergroup 0 2014-01-02 14:38 /foodir
drwxr-xr-x - root supergroup 0 2014-02-19 23:40 /input
drwxr-xr-x - root supergroup 0 2014-02-19 23:44 /output
[root@slave hadoop]# bin/hadoop fs -ls /output
Found 2 items
-rw-r--r-- 1 root supergroup 0 2014-02-19 23:44 /output/_SUCCESS
-rw-r--r-- 1 root supergroup 68 2014-02-19 23:44 /output/part-r-00000
[root@slave hadoop]# bin/hadoop fs -cat /output/part-r-00000
11 1
2222 1
Hello 1
Helloyctc 1
World 1
kong 2
kongxianghe 1
yctc 1
[root@slave hadoop]#
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- R的package虽多,感觉跟C++的比,还是差太远
- POJ 2010 - Moo University - Financial Aid （优先队列）
- Web
- STM32F407 RTC 配置理解与总结
- UVA 11235
- String是最基本的数据类型吗
- POJ 1273 Drainage Ditches 最大流
- POJ 1273 Drainage Ditches 最大流
- Codeforces Round #230 (Div. 2) C. Blocked Points D. Tower of Hanoi
- Ubuntu 下 nginx , php , mysql 和 golang 的简单安装
- 源文件与模块生成时的文件不同 [vs2008]
- linux使用小技巧
- python包
- 面向对象的特征有哪些方面
- 谈谈应届生应聘的一点看法
- 在链表结尾插入一个结点 以及在 在链表中找到第一个含有某值的结点并删除该结点
- codeforces 392A Blocked Points
- 电脑ping手机该怎么玩（很多网友都说电脑ping不通手机）？
- linux 开源文章篇
- 【PAT 1055】The World's Richest 结构体排序&剪枝