Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

Override hadoop's mapreduce.fileoutputcommitter.marksuccessfuljobs in oozie

<property>
<name>mapreduce.fileoutputcommitter.marksuccessfuljobs</name>
<value>false</value>
</property>

I want to override the above property to true. The property needs to be false for the rest of the jobs on the cluster, but I need, in my oozie workflow, hadoop to create _SUCCESS file in the output directory after the completion of job. Its a hive action in the workflow which writes output. Please help.

like image 714
Bhargav Avatar asked Oct 22 '12 18:10

Bhargav


2 Answers

Hive unfortunately overrides this capability by setting it's own NullOutputComitter:

conf.setOutputCommitter(NullOutputCommitter.class);

see

src/shims/src/0.20/java/org/apache/hadoop/hive/shims/Hadoop20Shims.java
src/shims/src/common-secure/java/org/apache/hadoop/hive/shims/HadoopShimsSecure.java

Looks like you'll have to create the flag manually. We have filed HIVE-3700 for this.

like image 76
Matthew Rathbone Avatar answered Nov 19 '22 06:11

Matthew Rathbone


You can add 'dfs' command to your hive script, like

dfs -touchz '$table_base_path'/dt='${partition}'/_SUCCESS

https://archive.cloudera.com/cdh4/cdh/4/hive/language_manual/cli.html

like image 2
Doroshenko Avatar answered Nov 19 '22 07:11

Doroshenko