There are basically two jobs. 1. manager job 2. child job
Manager job is running on Oozie and responsible for creating new instances of child jobs in Oozie when needed. I can see the manager job run in Oozie without giving any error. When the submitDispatcherJobForTenantToOozie(String tenantId) method invoked in manager job, it should submit a new child job to Oozie. The method is invoking properly. But I cannot see any child job in Oozie console. But When I run the manager job directly in hadoop(Without using Oozie), it spawns new child jobs in Oozie properly. On Wed, Jan 13, 2016 at 6:20 PM, Hanmay Udgiri <[email protected]> wrote: > So are u able to see the job running in HUE?.U can also view job in the > oozie web console ? What about the workflow.xml of tenantapp?Is > The MainClass job able to call tenantapp workflow? On 13-Jan-2016 6:09 pm, "Asanka Sanjaya Herath" <[email protected]> wrote: > > > Java method to create a job in Oozie. > > > > private void submitDispatcherJobForTenantToOozie(String tenantId) > > throws OozieClientException { > > > > // get a OozieClient for local Oozie > > OozieClient wc = new > > > OozieClient(PropertyValuesProvider.getInstance().getPropValue("oozieURL")); > > > > // create a workflow job configuration and set the workflow > > application path > > Properties conf = wc.createConfiguration(); > > conf.setProperty(OozieClient.APP_PATH, > > PropertyValuesProvider.getInstance(). > > getPropValue("dispatcherTenantManagerAppPath")); > > > > // setting workflow parameters > > conf.setProperty("jobTracker", "sandbox.hortonworks.com:8050"); > > conf.setProperty("nameNode", "hdfs://sandbox.hortonworks.com:8020"); > > conf.setProperty("queueName", "default"); > > conf.setProperty("appRoot", "email-dispatcher-tenant-manager-1.0"); > > > > //set tenantId and retention period > > conf.setProperty("tenantId", tenantId); > > > > // submit and start the workflow job > > String jobId = wc.run(conf); > > } > > > > > > Workfolw.xml of child job: > > > > > > <workflow-app xmlns="uri:oozie:workflow:0.2" name="java-main-wf"> > > <start to="java-node"/> > > <action name="java-node"> > > <java> > > <job-tracker>${jobTracker}</job-tracker> > > <name-node>${nameNode}</name-node> > > <configuration> > > <property> > > <name>mapred.job.queue.name</name> > > <value>${queueName}</value> > > </property> > > </configuration> > > <main-class>com.MainClass</main-class> > > </java> > > <ok to="end"/> > > <error to="fail"/> > > </action> > > <kill name="fail"> > > <message>Java failed, error > > message[${wf:errorMessage(wf:lastErrorNode())}]</message> > > </kill> > > <end name="end"/> > > </workflow-app> > > > > > > > > On Wed, Jan 13, 2016 at 6:00 PM, Hanmay Udgiri < > [email protected]> > > wrote: > > > > > Can u share the workflow.xml or the java code? > > > On 13-Jan-2016 17:34, "Asanka Sanjaya Herath" <[email protected]> > > wrote: > > > > > > > Hi Hanmayya, > > > > > > > > I followed the given link but it failed to spawn new Oozie jobs. But > > > when I > > > > run the same program directly using yarn jar command It spawns the > jobs > > > in > > > > Oozie. The yarn log is not giving any errors too. > > > > > > > > On Wed, Jan 13, 2016 at 11:42 AM, Asanka Sanjaya Herath < > > > > [email protected]> > > > > wrote: > > > > > > > > > Hi Hanmayya, > > > > > > > > > > Thank you for the response. I'll follow the given link and update > > > status. > > > > > > > > > > > > > > >> Do you want to execute multiple Oozie workflows from the Java > > class? > > > > > > > > > > > > > > > No I want to execute set of instances of one Oozie workflow. > > > > > > > > > > > > > > > On Wed, Jan 13, 2016 at 10:43 AM, Hanmay Udgiri < > > > > [email protected] > > > > > > wrote: > > > > > > > > > >> You can use OozieClient Java class. > > > > >> > > > > >> > > > > >> > > > > > > > > > > http://www.hadooped.blogspot.in/2013/06/apache-oozie-part-8-java-api-for.html > > > > >> > > > > >> Do you want to execute multiple Oozie workflows from the Java > class? > > > > >> > > > > >> Thanks > > > > >> Hanmayya > > > > >> > > > > >> On Wed, Jan 13, 2016 at 9:57 AM, Asanka Sanjaya Herath < > > > > >> [email protected]> > > > > >> wrote: > > > > >> > > > > >> > Hi, > > > > >> > > > > > >> > I'm writing a simple Java Oozie job. That job is supposed to > spawn > > > new > > > > >> > Oozie jobs or directly submit new jobs to Hadoop. Is there a way > > to > > > > >> achieve > > > > >> > this using Oozie API? > > > > >> > > > > > >> > -- > > > > >> > Thanks, > > > > >> > Regards, > > > > >> > ASH > > > > >> > > > > > >> > > > > >> > > > > >> > > > > >> -- > > > > >> Thanks and Regards > > > > >> Hanmayya Udgiri > > > > >> > > > > > > > > > > > > > > > > > > > > -- > > > > > Thanks, > > > > > Regards, > > > > > ASH > > > > > > > > > > > > > > > > > > > > > -- > > > > Thanks, > > > > Regards, > > > > ASH > > > > > > > > > > > > > > > -- > > Thanks, > > Regards, > > ASH > > > -- Thanks, Regards, ASH
