check job success

azkaban/3s_postback/3s_postback_install_list_v2.sh

@@ -21,6 +21,10 @@ hadoop jar ../${JAR} mobvista.dmp.main.ParseInstallRCFile \
   -Dmapreduce.fileoutputcommitter.algorithm.version=2 \
   ${INPUT_PATH} ${OUTPUT_PATH} ${REDUCE_NUM}
 
+if [ $? -ne 0 ];then
+  exit 255
+fi
+
 mount_partition "dm_install_list_v2" "dt='$LOG_TIME', business='${business}'" "$OUTPUT_PATH"
 if [ $? -ne 0 ];then
   exit 255

azkaban/ad_server_campaign/adserver_install_list_v2.sh

@@ -21,12 +21,11 @@ hadoop fs -rm -r $OUTPUT_PATH
 
 
 hadoop jar ../${JAR} mobvista.dmp.main.ParseInstallRCFile $INPUT_PATH $OUTPUT_PATH 100
+
 if [ $? -ne 0 ];then
   exit 255
 fi
 
-
-
 mount_partition "dm_install_list_v2" "dt='$LOG_TIME', business='adserver'" "$OUTPUT_PATH"
 if [ $? -ne 0 ];then
   exit 255

azkaban/adn_sdk/adn_sdk_install_v2.sh

@@ -25,6 +25,10 @@ hadoop jar ../${JAR} mobvista.dmp.main.ParseInstallRCFile \
   -Dmapreduce.fileoutputcommitter.algorithm.version=2 \
   ${INPUT_PATH} ${OUTPUT_PATH} ${REDUCE_NUM}
 
+if [ $? -ne 0 ];then
+  exit 255
+fi
+
 : '
 business="adn_sdk"
 

azkaban/ali/ali_install_list_v2.sh

@@ -27,6 +27,10 @@ hadoop jar ../${JAR} mobvista.dmp.main.ParseInstallRCFile \
   -Dmapreduce.fileoutputcommitter.algorithm.version=2 \
   ${INPUT_PATH} ${OUTPUT_PATH} 100
 
+if [ $? -ne 0 ];then
+  exit 255
+fi
+
 : '
 spark-submit --class mobvista.dmp.datasource.dm.DmInstallListOrc \
      --name "mobvista.dmp.datasource.dm.DmInstallListOrc.${business}" \

azkaban/bytedance/bytedance_install_list_v2.sh

@@ -26,6 +26,10 @@ hadoop jar ../${JAR} mobvista.dmp.main.ParseInstallRCFile \
   -Dmapreduce.fileoutputcommitter.algorithm.version=2 \
   ${INPUT_PATH} ${OUTPUT_PATH} ${REDUCE_NUM}
 
+if [ $? -ne 0 ];then
+  exit 255
+fi
+
 unset HADOOP_CLASSPATH
 
 mount_partition "dm_install_list_v2" "dt='$LOG_TIME', business='${business}'" "$OUTPUT_PATH"

azkaban/clever/adn_clever_install_v2.sh

@@ -23,6 +23,10 @@ hadoop jar ../${JAR} mobvista.dmp.main.ParseInstallRCFile \
   -Dmapreduce.fileoutputcommitter.algorithm.version=2 \
   $INPUT_PATH $OUTPUT_PATH 20
 
+if [ $? -ne 0 ];then
+  exit 255
+fi
+
 : '
 business="clever"
 spark-submit --class mobvista.dmp.datasource.dm.DmInstallListOrc \

azkaban/dm/install_list_other_v2.sh

@@ -23,6 +23,9 @@ hadoop jar ../${JAR} mobvista.dmp.main.ParseInstallRCFile \
   -Dmapreduce.fileoutputcommitter.algorithm.version=2 \
   $INPUT_PATH $OUTPUT_PATH 200
 
+if [ $? -ne 0 ];then
+  exit 255
+fi
 
 : '
 business="other"

azkaban/dsp/dsp_req_pkg_total_v2.sh

@@ -25,6 +25,10 @@ hadoop jar ../${JAR} mobvista.dmp.main.ParseInstallRCFile \
   -Dmapreduce.fileoutputcommitter.algorithm.version=2 \
   $INPUT_PATH $OUTPUT_PATH 6000
 
+if [ $? -ne 0 ];then
+  exit 255
+fi
+
 : '
 business="dsp_req"
 

azkaban/facebook/facebook_install_list_v2.sh

@@ -27,6 +27,9 @@ hadoop jar ../${JAR} mobvista.dmp.main.ParseInstallRCFile \
   -Dmapreduce.fileoutputcommitter.algorithm.version=2 \
   ${INPUT_PATH} ${OUTPUT_PATH} ${REDUCE_NUM}
 
+if [ $? -ne 0 ];then
+  exit 255
+fi
 
 unset HADOOP_CLASSPATH
 

azkaban/iqiyi/iqiyi_install_list_v2.sh

@@ -25,6 +25,10 @@ hadoop jar ../${JAR} mobvista.dmp.main.ParseInstallRCFile \
   -Dmapreduce.fileoutputcommitter.algorithm.version=2 \
   ${INPUT_PATH} ${OUTPUT_PATH} 10
 
+if [ $? -ne 0 ];then
+  exit 255
+fi
+
 unset HADOOP_CLASSPATH
 
 mount_partition "dm_install_list_v2" "dt='$LOG_TIME', business='${business}'" "$OUTPUT_PATH"

azkaban/joypac/joypac_install_list_v2.sh

@@ -27,6 +27,10 @@ hadoop jar ../${JAR} mobvista.dmp.main.ParseInstallRCFile \
   -Dmapreduce.fileoutputcommitter.algorithm.version=2 \
   ${INPUT_PATH} ${OUTPUT_PATH} ${REDUCE_NUM}
 
+if [ $? -ne 0 ];then
+  exit 255
+fi
+
 unset HADOOP_CLASSPATH
 
 # mount_partition "dm_install_list_v2" "dt='$LOG_TIME', business='${business}'" "$OUTPUT_PATH"

azkaban/mp/mp_request_install_list_v2.sh

@@ -22,6 +22,10 @@ reduce_num=`calculate_reduce_num "${INPUT_PATH}"`
 
 hadoop jar ../${JAR} mobvista.dmp.main.ParseInstallRCFile $INPUT_PATH $OUTPUT_PATH ${reduce_num}
 
+if [ $? -ne 0 ];then
+  exit 255
+fi
+
 : '
 business="mp"
 spark-submit --class mobvista.dmp.datasource.dm.DmInstallListOrc \

azkaban/retarget_dealerid/dsp_dealer_install_list_v2.sh

@@ -19,6 +19,10 @@ REDUCE_NUM=$(calculate_reduce_num ${INPUT_PATH})
 
 hadoop jar ../${JAR} mobvista.dmp.main.ParseInstallRCFile ${INPUT_PATH} ${OUTPUT_PATH} ${REDUCE_NUM}
 
+if [ $? -ne 0 ];then
+  exit 255
+fi
+
 mount_partition "dm_install_list_v2" "dt='$LOG_TIME', business='${business}'" "$OUTPUT_PATH"
 if [ $? -ne 0 ];then
   exit 255