Hi,
I am currently working with Pig. I get struck with following script.
A = load 'sample.txt';
B = MAPREDUCE '/home/training/simp.jar' Store A into 'inputDir' Load
'outputDir' as (word:chararray, count: int) `WordCount inputDir outputDir`;
dump B;
Error :
2014-07-04 11:17:57,811 [main] WARN org.apache.hadoop.mapred.JobClient -
No job jar file set. User classes may not be found. See JobConf(Class) or
JobConf#setJar(String).
2014-07-04 11:18:16,313 [main] INFO org.apache.hadoop.mapred.JobClient -
Task Id : attempt_201407011531_0147_m_000000_2, Status : FAILED
java.lang.RuntimeException: java.lang.ClassNotFoundException: Class
WordCount$Map not found
at
org.apache.hadoop.conf.Configuration.getClass(Configuration.java:1774)
at
org.apache.hadoop.mapreduce.task.JobContextImpl.getMapperClass(JobContextImpl.java:191)
at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:631)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:330)
at org.apache.hadoop.mapred.Child$4.run(Child.java:268)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:396)
at
org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1438)
at org.apache.hadoop.mapred.Child.main(Child.java:262)
Caused by: java.lang.ClassNotFoundException: Class WordCount$Map not found
at
org.apache.hadoop.conf.Configuration.getClassByName(Configuration.java:1680)
at
org.apache.hadoop.conf.Configuration.getClass(Configuration.java:1772)
please help me to solve the problem
regards,
Nivetha.
