3.5.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
DataHubScheduler
application UI
Details for Stage 2561 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
88 ms
Locality Level Summary:
Process local: 5
Input Size / Records:
55.1 KiB / 3
Output Size / Records:
0.0 B / 62
Associated Job Ids:
1991
DAG Visualization
digraph G { subgraph clusterstage_2561 { label="Stage 2561"; 9152 [labelType="html" label="SQLExecutionRDD [9152] [Unordered]<br>jdbc at <unknown>:0"]; subgraph cluster20174 { label="Exchange"; 8797 [labelType="html" label="ShuffledRowRDD [8797] [Unordered]<br>javaToPython at <unknown>:0"]; } subgraph cluster20161 { label="WholeStageCodegen (3)"; 8799 [labelType="html" label="MapPartitionsRDD [8799] [Unordered]<br>javaToPython at <unknown>:0"]; } subgraph cluster20106 { label="AdaptiveSparkPlan"; 8801 [labelType="html" label="MapPartitionsRDD [8801] [Unordered]<br>javaToPython at <unknown>:0"]; 8804 [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#743566, summary__config_version#743567, summary__entity_id#743568, summary__submission_status#743569, summary__is_latest#743570, summary__is_editable#743571, summary__launch_date#743572, summary__expiry_date#743573, summary__submitted_date#743574, summary__create_ts#743575, summary__update_ts#743576, summary__create_date#743577, summary__update_date#743619, summary__source#743620, summary__recurrence_count#743634, summary__priority#743635, summary__remarks#743636, summary__latest_source#743637, summary__launch_request_name#743638, summary__NetworkID#743639, ... 49 more fields]\n +- BroadcastHashJoin [brand_context_id#584899, company_id#584900, launch_config_ref#584901, revision_version#584902], [brand_context_id#726654, company_id#726655, launch_config_ref#726656, revision_version#726657], Inner, BuildLeft, false\n :- BroadcastExchange Hash... [8804] [Cached] [Unordered]<br>javaToPython at <unknown>:0"]; } subgraph cluster20885 { label="InMemoryTableScan"; 9145 [labelType="html" label="MapPartitionsRDD [9145] [Unordered]<br>jdbc at <unknown>:0"]; 9146 [labelType="html" label="MapPartitionsRDD [9146] [Unordered]<br>jdbc at <unknown>:0"]; 9147 [labelType="html" label="MapPartitionsRDD [9147] [Unordered]<br>jdbc at <unknown>:0"]; } subgraph cluster20883 { label="Filter"; 9148 [labelType="html" label="MapPartitionsRDD [9148] [Unordered]<br>jdbc at <unknown>:0"]; } subgraph cluster20882 { label="Project"; 9149 [labelType="html" label="MapPartitionsRDD [9149] [Unordered]<br>jdbc at <unknown>:0"]; } subgraph cluster20877 { label="WholeStageCodegen (1)"; 9150 [labelType="html" label="MapPartitionsRDD [9150] [Unordered]<br>jdbc at <unknown>:0"]; } subgraph cluster20876 { label="DeserializeToObject"; 9151 [labelType="html" label="MapPartitionsRDD [9151] [Unordered]<br>jdbc at <unknown>:0"]; } subgraph cluster20886 { label="mapPartitions"; 9154 [labelType="html" label="MapPartitionsRDD [9154] [Unordered]<br>jdbc at <unknown>:0"]; } } 8797->8799; 8799->8801; 8801->8804; 8804->9145; 9145->9146; 9146->9147; 9147->9148; 9148->9149; 9149->9150; 9150->9151; 9151->9152; 9152->9154; }
8772,8797
8804
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