-----原始邮件-----
发件人:enyun <[email protected]>
发送时间:2011年12月12日 星期一
收件人:[email protected], "[email protected]" <[email protected]>
主题:how to add -mapred.job.queue.name support for mahout modules ?
hi all,
I'm learning hadoop mahout recently, but the hadoop platform need I to specify
the job.queue name.
I'm trying to run the traninclassifier example with the parameter
"-mapred.job.queue.name=MYQUEUE", but mahout throws error ...
Do you guys know how to specify queue.name with mahout?
The example :
mahout trainclassifier -mapred.job.queue.name=search-product -i
/examples/bin/work/20news-bydate/bayes-train-input -o
/examples/bin/work/20news-bydate/bayes-model -type bayes -ng 1 -source hdfs
The error:
+ /home/knowledge/work/project/mahout/mahout-distribution-0.5/bin/mahout
trainclassifier -mapred.job.queue.name=MYQUEUE -i
/examples/bin/work/20news-bydate/bayes-train-input -o
/examples/bin/work/20news-bydate/bayes-model -type bayes -ng 1 -source hdfs
Running on hadoop, using HADOOP_HOME=/opt/hadoop/program/
HADOOP_CONF_DIR=/opt/hadoop/program/conf
11/12/12 11:43:24 ERROR bayes.TrainClassifier: Error while parsing options
org.apache.commons.cli2.OptionException: Unexpected
-mapred.job.queue.name=search-product while processing Options
at org.apache.commons.cli2.commandline.Parser.parse(Parser.java:99)
at
org.apache.mahout.classifier.bayes.TrainClassifier.main(TrainClassifier.java:114)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at
org.apache.hadoop.util.ProgramDriver$ProgramDescription.invoke(ProgramDriver.java:68)
at org.apache.hadoop.util.ProgramDriver.driver(ProgramDriver.java:139)
at org.apache.mahout.driver.MahoutDriver.main(MahoutDriver.java:187)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.apache.hadoop.util.RunJar.main(RunJar.java:156)
