workflow - Falcon & Oozie - How to configure job.properties for oozie in falcon -


i have oozie workflow calls sqoop , hive action. individual workflow works fine when run oozie command line. since sqoop , hive scripts vary, pass values workflow.xml using job.properties file.

sudo oozie job -oozie http://hostname:port/oozie -config job.properties -run

now want configure oozie workflow in falcon. can please me in figuring out can configure or pass job.properties?

below falcon process.xml

<process name="demoprocess" xmlns="uri:falcon:process:0.1"> <tags>pipeline=degingestdatapipeline,owner=hadoop, externalsystem=svservers</tags> <clusters>     <cluster name="democluster">         <validity start="2015-01-30t00:00z" end="2016-02-28t00:00z"/>     </cluster> </clusters> <parallel>1</parallel> <order>fifo</order> <frequency>hours(1)</frequency> <outputs>     <output name="output" feed="demofeed" instance="now(0,0)" /> </outputs>  <workflow name="dev-wf" version="0.2.07" engine="oozie" path="/apps/demo/workflow.xml" />  <retry policy="periodic" delay="minutes(15)" attempts="3" /> </process>

i not find on web or falcon documentation regarding this.

i worked on development in falcon did not try falcon vanilla lot, understand tutorial below:

http://hortonworks.com/hadoop-tutorial/defining-processing-data-end-end-data-pipeline-apache-falcon/

i try creating oozie-workflow.xml accepts job.properties dynamically. place properties file in respective hdfs folder workflow.xml picks , can change every process. can use falcon process.xml , call command line using:

falcon entity -type process -submit -file process.xml

also in path=/apps/demo/workflow.xml need not specify workflow.xml explicitly. can give folder name, example:

<process name="rawemailingestprocess" xmlns="uri:falcon:process:0.1">  <tags>pipeline=churnanalysisdatapipeline,owner=etlgroup,externalsystem=uswestemailservers</tags>   <clusters>     <cluster name="primarycluster">         <validity start="2014-02-28t00:00z" end="2016-03-31t00:00z"/>     </cluster> </clusters>  <parallel>1</parallel> <order>fifo</order> <frequency>hours(1)</frequency>  <outputs>     <output name="output" feed="rawemailfeed" instance="now(0,0)" /> </outputs>  <workflow name="emailingestworkflow" version="2.0.0" engine="oozie" path="/user/ambari-qa/falcon/demo/apps/ingest/fs" />  <retry policy="periodic" delay="minutes(15)" attempts="3" />


-

Comments

Post a Comment

Popular posts from this blog

css - SVG using textPath a symbol not rendering in Firefox -

using textpath within symbol doesn't render in firefox. renders fine in latest chrome , ie, when try reference symbol, svg text doesn't render in firefox (37.0.1) - first box appears empty. code below (no external dependencies), there should 2 boxes word test flowing vertically in centre of each. edit: thought issue somehow involved flexbox layout, until paul pointed out issue exists without flexbox layout. the html is: <div> <svg id="not_working" viewbox="0 0 250 1200" preserveaspectratio="xmidymid meet"> <symbol id="test_symbol1" preserveaspectratio="xmidymid meet" viewbox="0 0 250 1200"> <path id="test_symbol_path" d="m 100 1200 l 100 0" /> <text font-size="100" fill="red"> <textpath text-anchor="middle" startoffset="50%" xlink:href="#test_symbol_path...
Read more

Java 8 + Maven Javadoc plugin: Error fetching URL -

i attempting generate javadoc links javadoc dependencies. have tried various means generate javadoc not produce qualified class names references classes dependencies. wanted links java doc simplified class names. however, java api classnames, no links , have qualified class names. working java 8. have following configuration: <plugin> <groupid>org.apache.maven.plugins</groupid> <artifactid>maven-javadoc-plugin</artifactid> <version>2.10.2</version> <configuration> <reportoutputdirectory>${project.basedir}/target</reportoutputdirectory> <destdir>javadoc</destdir> <windowtitle>epiphany</windowtitle> <doctitle>epiphany</doctitle> <show>private</show> <detectlinks>false</detectlinks> <detectoffline...
Read more

datatable - Matlab struct computations -

i download data yahoo! finance with: data = getyahoodailydata({'msft', 'axp'},'01/01/2000', '01/01/2015', 'dd/mm/yyyy'); and data stored 1x1 struct. want create tx2 matrix of daily adjusted closing prices msft , axp, column 7 in each table in struct. how can that? or better : there way make computations directly on information/prices in struct? you can access data in struct name. vecmsftadj = data.msft.adjclose; vecaxpadj = data.axp.adjclose; % if want n x 2 matrix madjclose = [vecmsftadj, vecaxpadj]; % personnaly prefer working table tadjclose = table; tadjclose.msftadj = vecmsftadj; tadjclose.axpadj = vecaxpadj;
Read more