3.5.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
DataHubScheduler
application UI
Details for Stage 2482 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
8 ms
Locality Level Summary:
Process local: 5
Input Size / Records:
49.2 KiB / 3
Associated Job Ids:
1943
DAG Visualization
digraph G { subgraph clusterstage_2482 { label="Stage 2482"; subgraph cluster20104 { label="Exchange"; 8767 [labelType="html" label="ShuffledRowRDD [8767] [Unordered]<br>javaToPython at <unknown>:0"]; } subgraph cluster20095 { label="WholeStageCodegen (3)"; 8768 [labelType="html" label="MapPartitionsRDD [8768] [Unordered]<br>javaToPython at <unknown>:0"]; } subgraph cluster20022 { label="AdaptiveSparkPlan"; 8769 [labelType="html" label="MapPartitionsRDD [8769] [Unordered]<br>javaToPython at <unknown>:0"]; 8770 [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#731443, summary__config_version#731444, summary__entity_id#731445, summary__submission_status#731446, summary__is_latest#731447, summary__is_editable#731448, summary__launch_date#731449, summary__expiry_date#731450, summary__submitted_date#731451, summary__create_ts#731452, summary__update_ts#731453, summary__create_date#731454, summary__update_date#731455, summary__source#731457, summary__recurrence_count#731458, summary__priority#731506, summary__remarks#731507, summary__latest_source#731508, summary__launch_request_name#731649, summary__NetworkID#731650, ... 49 more fields]\n +- BroadcastHashJoin [brand_context_id#584899, company_id#584900, launch_config_ref#584901, revision_version#584902], [brand_context_id#719996, company_id#719997, launch_config_ref#719998, revision_version#719999], Inner, BuildLeft, false\n :- BroadcastExchange Hash... [8770] [Cached] [Unordered]<br>javaToPython at <unknown>:0"]; } subgraph cluster20130 { label="InMemoryTableScan"; 8784 [labelType="html" label="MapPartitionsRDD [8784] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 8785 [labelType="html" label="MapPartitionsRDD [8785] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 8786 [labelType="html" label="MapPartitionsRDD [8786] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster20125 { label="WholeStageCodegen (1)"; 8787 [labelType="html" label="MapPartitionsRDD [8787] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster20124 { label="BroadcastExchange"; 8788 [labelType="html" label="MapPartitionsRDD [8788] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } } 8767->8768; 8768->8769; 8769->8770; 8770->8784; 8784->8785; 8785->8786; 8786->8787; 8787->8788; }
8745,8767
8770
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