It is -Dmapred.x.x.x.=yyy . (This is the usual Java syntax for setting
properties.)


---------- Forwarded message ----------
From: enyun <[email protected]>
Date: 2011/12/11
Subject: how to add -mapred.job.queue.name support for mahout modules ?
To: [email protected]






-----原始邮件-----
发件人: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)






-- 
Lance Norskog
[email protected]

Reply via email to