I also try this method, but doesn't work. I'm trying to change the source code to add queue.name support, but failed. thanks,
At 2011-12-13 10:13:43,"Lance Norskog" <[email protected]> wrote: >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]
