update mapping

azkaban/backflow/mapping/mapping.sh

@@ -64,7 +64,7 @@ spark-submit --class mobvista.dmp.datasource.backflow.BackFlow \
   --conf spark.kryoserializer.buffer.max=512m \
   --conf spark.kryoserializer.buffer=64m \
   --master yarn --deploy-mode cluster \
-  --executor-memory 4g --driver-memory 4g --executor-cores 3 --num-executors 4 \
+  --executor-memory 4g --driver-memory 4g --executor-cores 4 --num-executors 6 \
   ../.././DMP.jar \
   -keyspace ${keyspace} -table ${table} -region ${region} -output ${output} -system ${system} \
   -writetime_start ${writetime_start} -writetime_end ${writetime_end} -value_column ${value_column}

azkaban/backflow/mapping/mapping_filter.sh

@@ -21,7 +21,7 @@ spark-submit --class mobvista.dmp.datasource.backflow.BackFlowFilter \
   --conf spark.kryoserializer.buffer.max=512m \
   --conf spark.kryoserializer.buffer=64m \
   --master yarn --deploy-mode cluster \
-  --executor-memory 4g --driver-memory 4g --executor-cores 2 --num-executors 20 \
+  --executor-memory 4g --driver-memory 4g --executor-cores 3 --num-executors 60 \
   ../.././DMP.jar \
   -output ${output} -date ${date}