Skip to content
This repository was archived by the owner on Jan 8, 2019. It is now read-only.

Forked Smoke-Tests #1241

Merged
merged 1 commit into from
Jul 18, 2018
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,6 @@ queueName=default
mapTasks=10
reduceTasks=1
oozie.use.system.libpath=true
queueName=default
oozie.wf.application.path=<%= @smoke['hdfs_wf_path'] %>
inputDir=inputForPi
outputDir=outputForPi
Expand Down
56 changes: 37 additions & 19 deletions cookbooks/smoke-tests/templates/default/smoke_test_xml.erb
Original file line number Diff line number Diff line change
Expand Up @@ -65,16 +65,29 @@
</property>
</credential>
</credentials>
<start to="Shell-Action"/>

<start to="Smoke-Test-Fork"/>

<fork name="Smoke-Test-Fork">
<path start="Shell-Action"/>
<path start="MapReduce-Action"/>
<path start="Hive-Smokes"/>
<path start="Hive2-Smokes"/>
<path start="Hive-CLI"/>
<path start="HBASE-Shell"/>
</fork>



<action name="Shell-Action">
<shell xmlns="uri:oozie:shell-action:0.1">
<job-tracker>${jobTracker}</job-tracker>
<name-node>${nameNode}</name-node>
<exec>sleep</exec>
<argument>10</argument>
</shell>
<ok to="MapReduce-Action"/>
<error to="fail"/>
<ok to="join-smokes"/>
<error to="join-smokes"/>
</action>
<action name="MapReduce-Action">
<map-reduce>
Expand Down Expand Up @@ -148,14 +161,10 @@
</property>
</configuration>
</map-reduce>
<ok to="forkNode"/>
<error to="fail"/>
<ok to="join-smokes"/>
<error to="join-smokes"/>
</action>
<fork name="forkNode">
<path start="Hive-Smokes"/>
<path start="Hive2-Smokes"/>
</fork>


<action name="Hive-Smokes" cred="hcat_creds">
<hive xmlns="uri:oozie:hive-action:0.2">
<job-tracker>${jobTracker}</job-tracker>
Expand All @@ -171,8 +180,8 @@
<param>HIVE_SMOKE_TEST_DB=smoke_test_db</param>
<param>HIVE_SMOKE_TEST_TBL=smoke_test_tbl</param>
</hive>
<ok to="joiner"/>
<error to="fail"/>
<ok to="join-smokes"/>
<error to="join-smokes"/>
</action>

<action name="Hive2-Smokes" cred="hive2_creds">
Expand All @@ -191,10 +200,9 @@
<param>HIVE_SMOKE_TEST_DB=smoke_test_db_v2</param>
<param>HIVE_SMOKE_TEST_TBL=smoke_test_tbl_v2</param>
</hive2>
<ok to="joiner"/>
<error to="fail"/>
<ok to="join-smokes"/>
<error to="join-smokes"/>
</action>
<join name="joiner" to="Hive-CLI"/>

<action name="Hive-CLI" cred="hcat_creds">
<shell xmlns="uri:oozie:shell-action:0.1">
Expand All @@ -204,8 +212,8 @@
<argument>-e</argument>
<argument>"show databases"</argument>
</shell>
<ok to="HBASE-Shell"/>
<error to="fail"/>
<ok to="join-smokes"/>
<error to="join-smokes"/>
</action>
<action name="HBASE-Shell" cred="hbase_creds">
<shell xmlns="uri:oozie:shell-action:0.1">
Expand All @@ -218,9 +226,19 @@
<argument>shell</argument>
<argument>-n</argument>
</shell>
<ok to="report-success-zabbix"/>
<error to="fail"/>
<ok to="join-smokes"/>
<error to="join-smokes"/>
</action>
<join name="join-smokes" to="status-decision"/>
<decision name="status-decision">
<switch>
<case to="report-success-zabbix">
${wf:lastErrorNode() eq null}
</case>
<default to="fail"/>
</switch>
</decision>

<action name="report-success-zabbix">
<shell xmlns="uri:oozie:shell-action:0.1">
<job-tracker>${jobTracker}</job-tracker>
Expand Down