You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@oozie.apache.org by Hanmay Udgiri <ha...@gmail.com> on 2016/02/11 12:55:57 UTC

Oozie job id inside Java MapReduce

Hi All,

I am running a Java MapReduce program using  oozie workflow. I want to
create DB entry with job ID as a key
How to get the current oozie job ID inside Java mapper class?

Thanks
Hanmayya

Re: Oozie job id inside Java MapReduce

Posted by Hanmay Udgiri <ha...@gmail.com>.

Perfect,

Thanks a lot
On 11-Feb-2016 5:31 pm, "Tousif" <to...@gmail.com> wrote:

> You can use *wf:id()*
>
> It returns the workflow job ID for the current workflow job.
>
> Add this to job configuration and access it inside your MR job by reading
> configuration.
> On 11 Feb 2016 17:26, "Hanmay Udgiri" <ha...@gmail.com> wrote:
>
> > Hi All,
> >
> > I am running a Java MapReduce program using  oozie workflow. I want to
> > create DB entry with job ID as a key
> > How to get the current oozie job ID inside Java mapper class?
> >
> > Thanks
> > Hanmayya
> >
>

Re: Oozie job id inside Java MapReduce

Posted by Tousif <to...@gmail.com>.

You can use *wf:id()*

It returns the workflow job ID for the current workflow job.

Add this to job configuration and access it inside your MR job by reading
configuration.
On 11 Feb 2016 17:26, "Hanmay Udgiri" <ha...@gmail.com> wrote:

> Hi All,
>
> I am running a Java MapReduce program using  oozie workflow. I want to
> create DB entry with job ID as a key
> How to get the current oozie job ID inside Java mapper class?
>
> Thanks
> Hanmayya
>