question Re: Need help on constructing oozie wf in Archives of Support Questions (Read Only)

Need help on constructing oozie wf

gobi_subramani — Wed, 05 Oct 2016 10:07:16 GMT

Hi,

My requirement is, I need to run the job in every 30 min.

I need to create folder (yyyymmdd) in this format dynamically.

I need to copy the data from the table and put it in to that generated table.

How do I acheive that. I have referred many link, but no luck.

also, kindly clarify below terms

<input-events> ,<output-events>, <datasets>,<uri-template>

Re: Need help on constructing oozie wf

pminovic — Wed, 05 Oct 2016 15:22:55 GMT

You need a Oozie coordinator and a workflow with 2 actions (if I understand your conditions correctly). Set the coordinator frequency = "0/30 * * * *" to run the workflow on every full hour, and 30 minutes after every hour. In your coordinator set a property named for example DATE and set its value like below, see here for details

${coord:formatTime(coord:nominalTime(), 'yyyy-MM-dd')}

In your workflow.xml, create 2 actions, the first will be an fs action to crate that directory, for example:

<mkdir path='${nameNode}/user/user1/data/${wf.conf("DATE")}' />

And the second action will be a hive or hive2 action to "copy the data from the table and put it in to that generated table". [For another coordinator example see this, and click "Previous page" links to find examples of the property file and a workflow with multiple actions, including hive actions.]

And finally, input-events and datasets is used if the condition for the coordinator to start is availability of a new dataset. uri-template is used to define a dataset, and output-events refers to the coordinator output. You can find more details here: datasets, coordinator concepts, and an example of a coordinator based on input-events. If you run your coordinator by time frequency you don't need that.

Re: Need help on constructing oozie wf

matt_andruff — Mon, 19 Aug 2019 11:10:55 GMT

@Gobi Subramani I would suggest that you download and install HDP. It can handle creating the data flow for you. Here's an example of it collecting logs. Instead of writing to an Event bus you could use putHDFS connector and it would write it to hdfs for you. There isn't a lot of trickery to get the date/folder to work, you just need to ${now()} in place of the folder name to get the schema you are looking for. If you look around there are lots of walk throughs and templates. I have included a pic of a simple flow that would likely solve your issue.