DAG: exchange-dsp-reporting_v002

schedule: 0 4 * * *


Task Instance: create_cluster_and_add_emr_steps


Rendered Template

job_flow_overrides
("{'Name': 'vd-uat-viooh-exchange-dsp-reporting', 'LogUri': "
 "'s3n://viooh-emr-logs-lab-cn/bigdata/emr/', 'ReleaseLabel': 'emr-5.35.0', "
 "'Instances': {'InstanceFleets': [{'Name': 'Masterfleet', "
 "'InstanceFleetType': 'MASTER', 'TargetOnDemandCapacity': 1, "
 "'InstanceTypeConfigs': [{'InstanceType': 'm5.xlarge'}, {'InstanceType': "
 "'m5.2xlarge'}, {'InstanceType': 'm5.4xlarge'}]}, {'Name': 'Corefleet', "
 "'InstanceFleetType': 'CORE', 'TargetOnDemandCapacity': 5, "
 "'InstanceTypeConfigs': [{'InstanceType': 'm5.xlarge'}, {'InstanceType': "
 "'m5.2xlarge'}, {'InstanceType': 'm5.4xlarge'}]}], 'Ec2KeyName': "
 "'data.engineer.lab', 'KeepJobFlowAliveWhenNoSteps': False, "
 "'TerminationProtected': False, 'Ec2SubnetId': 'subnet-06c5b5a18c64a0316', "
 "'EmrManagedMasterSecurityGroup': 'sg-0da002beeed87fb1a', "
 "'EmrManagedSlaveSecurityGroup': 'sg-0f1a0b7517309fcf0', "
 "'ServiceAccessSecurityGroup': 'sg-009528c399781cc69'}, 'BootstrapActions': "
 "[], 'Applications': [{'Name': 'Spark'}, {'Name': 'Hadoop'}, {'Name': "
 "'Ganglia'}, {'Name': 'Zeppelin'}], 'VisibleToAllUsers': True, 'Steps': "
 "[{'Name': 'Setup Hadoop Debugging', 'ActionOnFailure': 'TERMINATE_JOB_FLOW', "
 "'HadoopJarStep': {'Jar': 'command-runner.jar', 'Args': "
 "['state-pusher-script']}}, {'Name': 'DSPExchangeTradeJob', "
 "'ActionOnFailure': 'TERMINATE_CLUSTER', 'HadoopJarStep': {'Args': "
 "['spark-submit', '--deploy-mode', 'cluster', '--master', 'yarn', '--conf', "
 "'spark.yarn.submit.waitAppCompletion=true', '--conf', 'spark.app.env=uat', "
 "'--conf', 'spark.dag.execution.time=2024-06-16T04:00:00+00:00', '--class', "
 "'com.viooh.smex.dsp.DSPExchangeTrade', "
 "'s3://viooh-spark-artifacts-lab-cn/releases/com/viooh/smex/dsp-exchange-trade/2.11.0/dsp-exchange-trade-2.11.0-jar-with-dependencies.jar'], "
 "'Jar': 'command-runner.jar'}}, {'Name': 'CopyDSPReports', 'ActionOnFailure': "
 "'TERMINATE_JOB_FLOW', 'HadoopJarStep': {'Jar': "
 "'s3://cn-northwest-1.elasticmapreduce/libs/script-runner/script-runner.jar', "
 "'Args': "
 "['s3://viooh-spark-artifacts-lab-cn/scripts/exchange-dsp-reporting/1.0.0/job.sh', "
 "'--environment', 'uat', '--reportdate', '2024-06-16', '--region', 'cn', "
 "'--skipFailure']}}], 'JobFlowRole': 'DeEmrInstanceRole', 'ServiceRole': "
 "'DeEmrServiceRole', 'SecurityConfiguration': 'bigdata_emr_cn_sec_conf', "
 "'Tags': [{'Key': 'environment', 'Value': 'uat'}, {'Key': 'role', 'Value': "
 "'analysis'}, {'Key': 'application', 'Value': 'emr'}, {'Key': 'project', "
 "'Value': 'exchange-reporting'}, {'Key': 'TerminationPolicy', 'Value': "
 "'OFFICE-HOURS'}, {'Key': 'ContactEmail', 'Value': 'viooh.data@viooh.com'}, "
 "{'Key': 'team', 'Value': 'bigdata'}, {'Key': 'Name', 'Value': "
 "'vd-uat-viooh-exchange-dsp-reporting'}], 'Configurations': []}")