qq70191 发表于 2018-10-30 07:36:05

Hadoop2.6.0学习笔记(五)自定义InputFormat和RecordReader

$ hadoop jar RandomMR.jar /201512020027  
15/12/02 00:28:07 INFO client.RMProxy: Connecting to ResourceManager at nnode/192.168.137.117:8032
  
生成的随机数的值如下:
  
0.020075738
  
0.700349
  
0.9617876
  
0.8286018
  
0.03357637
  
0.55033255
  
0.112645924
  
0.43312508
  
0.33184355
  
0.6960902
  
0.23912054
  
0.8523424
  
0.4133852
  
0.028242588
  
0.9031814
  
0.39397871
  
0.38278967
  
0.5842654
  
0.4569224
  
0.4008881
  
0.2230537
  
0.92889327
  
0.20127994
  
0.09574646
  
0.23173904
  
0.4365906
  
0.11567855
  
0.027944028
  
0.6965957
  
0.78311944
  
0.2365641
  
0.8575301
  
0.07472658
  
0.5219022
  
0.9409952
  
0.7122519
  
0.8722465
  
0.30288923
  
0.51773626
  
0.91211754
  
0.93172425
  
0.38484365
  
0.44844115
  
0.24589789
  
0.83361626
  
0.40983224
  
0.9444963
  
0.12061542
  
0.8446641
  
0.5303581
  
0.11295539
  
0.094003916
  
0.11822218
  
0.4997149
  
0.98296344
  
0.48746037
  
0.31420535
  
0.1151396
  
0.7904337
  
0.80005115
  
0.18344402
  
0.8171619
  
0.8749699
  
0.48023254
  
0.0044505
  
0.43879867
  
0.22367835
  
0.62924916
  
0.6998315
  
0.222148
  
0.7392884
  
0.4174865
  
0.4528237
  
0.70034826
  
0.3057149
  
0.29177833
  
0.22782367
  
0.8182611
  
0.46680295
  
0.4778521
  
0.6365823
  
0.43971914
  
0.27055055
  
0.26839674
  
0.5263245
  
0.8824649
  
0.51182485
  
0.20494783
  
0.7679403
  
0.31936407
  
0.13476872
  
0.47281688
  
0.3402111
  
0.28706527
  
0.038203478
  
0.7351879
  
0.6165404
  
0.41761196
  
0.5229257
  
0.7284225
  
====================
  
15/12/02 00:28:08 INFO mapreduce.JobSubmitter: number of splits:2
  
15/12/02 00:28:08 INFO mapreduce.JobSubmitter: Submitting tokens for job: job_1448981819300_0014
  
15/12/02 00:28:09 INFO impl.YarnClientImpl: Submitted application application_1448981819300_0014
  
15/12/02 00:28:09 INFO mapreduce.Job: The url to track the job: http://nnode:8088/proxy/application_1448981819300_0014/
  
15/12/02 00:28:09 INFO mapreduce.Job: Running job: job_1448981819300_0014
  
15/12/02 00:28:38 INFO mapreduce.Job: Job job_1448981819300_0014 running in uber mode : false
  
15/12/02 00:28:38 INFO mapreduce.Job:map 0% reduce 0%
  
15/12/02 00:29:13 INFO mapreduce.Job:map 100% reduce 0%
  
15/12/02 00:29:32 INFO mapreduce.Job:map 100% reduce 100%
  
15/12/02 00:29:32 INFO mapreduce.Job: Job job_1448981819300_0014 completed successfully
  
15/12/02 00:29:32 INFO mapreduce.Job: Counters: 49
  
      File System Counters
  
                FILE: Number of bytes read=26
  
                FILE: Number of bytes written=323256
  
                FILE: Number of read operations=0
  
                FILE: Number of large read operations=0
  
                FILE: Number of write operations=0
  
                HDFS: Number of bytes read=520
  
                HDFS: Number of bytes written=31
  
                HDFS: Number of read operations=7
  
                HDFS: Number of large read operations=0
  
                HDFS: Number of write operations=2
  
      Job Counters
  
                Launched map tasks=2
  
                Launched reduce tasks=1
  
                Data-local map tasks=2
  
                Total time spent by all maps in occupied slots (ms)=64430
  
                Total time spent by all reduces in occupied slots (ms)=16195
  
                Total time spent by all map tasks (ms)=64430
  
                Total time spent by all reduce tasks (ms)=16195
  
                Total vcore-seconds taken by all map tasks=64430
  
                Total vcore-seconds taken by all reduce tasks=16195
  
                Total megabyte-seconds taken by all map tasks=65976320
  
                Total megabyte-seconds taken by all reduce tasks=16583680
  
      Map-Reduce Framework
  
                Map input records=2
  
                Map output records=2
  
                Map output bytes=16
  
                Map output materialized bytes=32
  
                Input split bytes=520
  
                Combine input records=0
  
                Combine output records=0
  
                Reduce input groups=1
  
                Reduce shuffle bytes=32
  
                Reduce input records=2
  
                Reduce output records=1
  
                Spilled Records=4
  
                Shuffled Maps =2
  
                Failed Shuffles=0
  
                Merged Map outputs=2
  
                GC time elapsed (ms)=356
  
                CPU time spent (ms)=1940
  
                Physical memory (bytes) snapshot=513851392
  
                Virtual memory (bytes) snapshot=2541506560
  
                Total committed heap usage (bytes)=257171456
  
      Shuffle Errors
  
                BAD_ID=0
  
                CONNECTION=0
  
                IO_ERROR=0
  
                WRONG_LENGTH=0
  
                WRONG_MAP=0
  
                WRONG_REDUCE=0
  
      File Input Format Counters
  
                Bytes Read=0
  
      File Output Format Counters
  
                Bytes Written=31
  
$


页: [1]
查看完整版本: Hadoop2.6.0学习笔记(五)自定义InputFormat和RecordReader