jeffreybreen / tutorial-201203-big-data Goto Github PK

Hi,
I follow the tutorial n`1 step by step and the all steps works very well except when I run code from R.
When I run the code below (with rmr-1-3)
cd
cd hadoop-r/airline/src/deptdelay_by_month/R/rmr/
export HADOOP_HOME=/usr/lib/hadoop
R

source('deptdelay-rmr12.R')
df = from.dfs(deptdelay("asa-airline/data", "asa-airline/out/deptdelaymonth-rmr"), to.data.frame=T)

I got this ERROR
packageJobJar: [/tmp/Rtmpylb4Ru/rmr-local-env, /tmp/Rtmpylb4Ru/rmr-global-env, /tmp/Rtmpylb4Ru/rhstr.map162538ef196a, /tmp/Rtmpylb4Ru/rhstr.reduce162517b13536, /var/lib/hadoop-0.20/cache/cloudera/hadoop-unjar5179862963461612531/] [] /tmp/streamjob9098009061696069986.jar tmpDir=null
12/09/16 12:05:26 WARN snappy.LoadSnappy: Snappy native library is available
12/09/16 12:05:26 INFO util.NativeCodeLoader: Loaded the native-hadoop library
12/09/16 12:05:26 INFO snappy.LoadSnappy: Snappy native library loaded
12/09/16 12:05:26 INFO mapred.FileInputFormat: Total input paths to process : 1
12/09/16 12:05:26 INFO streaming.StreamJob: getLocalDirs(): [/var/lib/hadoop-0.20/cache/cloudera/mapred/local]
12/09/16 12:05:26 INFO streaming.StreamJob: Running job: job_201209161135_0006
12/09/16 12:05:26 INFO streaming.StreamJob: To kill this job, run:
12/09/16 12:05:26 INFO streaming.StreamJob: /usr/lib/hadoop/bin/hadoop job -Dmapred.job.tracker=0.0.0.0:8021 -kill job_201209161135_0006
12/09/16 12:05:26 INFO streaming.StreamJob: Tracking URL: http://0.0.0.0:50030/jobdetails.jsp?jobid=job_201209161135_0006
12/09/16 12:05:27 INFO streaming.StreamJob: map 0% reduce 0%
12/09/16 12:06:05 INFO streaming.StreamJob: map 100% reduce 100%
12/09/16 12:06:05 INFO streaming.StreamJob: To kill this job, run:
12/09/16 12:06:05 INFO streaming.StreamJob: /usr/lib/hadoop/bin/hadoop job -Dmapred.job.tracker=0.0.0.0:8021 -kill job_201209161135_0006
12/09/16 12:06:06 INFO streaming.StreamJob: Tracking URL: http://0.0.0.0:50030/jobdetails.jsp?jobid=job_201209161135_0006
12/09/16 12:06:06 ERROR streaming.StreamJob: Job not successful. Error: NA
12/09/16 12:06:06 INFO streaming.StreamJob: killJob...
Streaming Command Failed!
Error in mr(map = map, reduce = reduce, combine = combine, in.folder = if (is.list(input)) { :
hadoop streaming failed with error code 1

I don't know what kind of information can be usefull to debug that.
I'm at your disposal...
Any idea ?