3.5.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
DataHubScheduler
application UI
Details for Stage 2505 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.1 s
Locality Level Summary:
Process local: 5
Input Size / Records:
52.5 KiB / 3
Output Size / Records:
0.0 B / 20
Associated Job Ids:
1957
DAG Visualization
digraph G { subgraph clusterstage_2505 { label="Stage 2505"; 8878 [labelType="html" label="SQLExecutionRDD [8878] [Unordered]<br>jdbc at <unknown>:0"]; subgraph cluster20053 { label="Exchange"; 8746 [labelType="html" label="ShuffledRowRDD [8746] [Unordered]<br>javaToPython at <unknown>:0"]; } subgraph cluster20035 { label="WholeStageCodegen (3)"; 8747 [labelType="html" label="MapPartitionsRDD [8747] [Unordered]<br>javaToPython at <unknown>:0"]; } subgraph cluster19993 { label="AdaptiveSparkPlan"; 8748 [labelType="html" label="MapPartitionsRDD [8748] [Unordered]<br>javaToPython at <unknown>:0"]; 8749 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#584899, company_id#584900, launch_config_ref#584901, revision_version#584902, summary__config_name#729058, summary__config_version#729059, summary__entity_id#729060, summary__submission_status#729061, summary__is_latest#729063, summary__is_editable#729133, summary__launch_date#729134, summary__expiry_date#729135, summary__submitted_date#729136, summary__create_ts#729137, summary__update_ts#729138, summary__create_date#729489, summary__update_date#729490, summary__source#730193, summary__recurrence_count#730194, summary__priority#730195, summary__remarks#730196, summary__latest_source#730197, summary__launch_request_name#730198, summary__NetworkID#730244, ... 49 more fields]\n +- BroadcastHashJoin [brand_context_id#584899, company_id#584900, launch_config_ref#584901, revision_version#584902], [brand_context_id#720038, company_id#720039, launch_config_ref#720040, revision_version#720041], Inner, BuildLeft, false\n :- BroadcastExchange Hash... [8749] [Cached] [Unordered]<br>javaToPython at <unknown>:0"]; } subgraph cluster20310 { label="InMemoryTableScan"; 8867 [labelType="html" label="MapPartitionsRDD [8867] [Unordered]<br>jdbc at <unknown>:0"]; 8872 [labelType="html" label="MapPartitionsRDD [8872] [Unordered]<br>jdbc at <unknown>:0"]; 8873 [labelType="html" label="MapPartitionsRDD [8873] [Unordered]<br>jdbc at <unknown>:0"]; } subgraph cluster20308 { label="Filter"; 8874 [labelType="html" label="MapPartitionsRDD [8874] [Unordered]<br>jdbc at <unknown>:0"]; } subgraph cluster20307 { label="Project"; 8875 [labelType="html" label="MapPartitionsRDD [8875] [Unordered]<br>jdbc at <unknown>:0"]; } subgraph cluster20296 { label="WholeStageCodegen (1)"; 8876 [labelType="html" label="MapPartitionsRDD [8876] [Unordered]<br>jdbc at <unknown>:0"]; } subgraph cluster20295 { label="DeserializeToObject"; 8877 [labelType="html" label="MapPartitionsRDD [8877] [Unordered]<br>jdbc at <unknown>:0"]; } subgraph cluster20311 { label="mapPartitions"; 8879 [labelType="html" label="MapPartitionsRDD [8879] [Unordered]<br>jdbc at <unknown>:0"]; } } 8746->8747; 8747->8748; 8748->8749; 8749->8867; 8867->8872; 8872->8873; 8873->8874; 8874->8875; 8875->8876; 8876->8877; 8877->8878; 8878->8879; }
8728,8746
8749
Event Timeline
Enable zooming
Tasks: 5. 1 Pages. Jump to
. Show
items in a page.
Go
Scheduler Delay
Task Deserialization Time
Shuffle Read Time
Executor Computing Time
Shuffle Write Time
Result Serialization Time
Getting Result Time