DataHubScheduler - Details for Stage 2434 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 0.1 s
Locality Level Summary: Process local: 5
Input Size / Records: 52.9 KiB / 3
Output Size / Records: 0.0 B / 16
Associated Job Ids: 1911

digraph G { subgraph clusterstage_2434 { label="Stage 2434"; 8553 [labelType="html" label="SQLExecutionRDD [8553] [Unordered] jdbc at <unknown>:0"]; subgraph cluster19477 { label="Exchange"; 8471 [labelType="html" label="ShuffledRowRDD [8471] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster19468 { label="WholeStageCodegen (3)"; 8472 [labelType="html" label="MapPartitionsRDD [8472] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster19448 { label="AdaptiveSparkPlan"; 8473 [labelType="html" label="MapPartitionsRDD [8473] [Unordered] javaToPython at <unknown>:0"]; 8474 [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#689812, summary__config_version#689813, summary__entity_id#689814, summary__submission_status#689815, summary__is_latest#689816, summary__is_editable#689817, summary__launch_date#689818, summary__expiry_date#689819, summary__submitted_date#689820, summary__create_ts#689821, summary__update_ts#689822, summary__create_date#689823, summary__update_date#689824, summary__source#689825, summary__recurrence_count#689826, summary__priority#689827, summary__remarks#689828, summary__latest_source#689829, summary__launch_request_name#689830, summary__NetworkID#689831, ... 49 more fields]\n +- BroadcastHashJoin [brand_context_id#584899, company_id#584900, launch_config_ref#584901, revision_version#584902], [brand_context_id#679909, company_id#679910, launch_config_ref#679911, revision_version#679912], Inner, BuildLeft, false\n :- BroadcastExchange Hash... [8474] [Cached] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster19628 { label="InMemoryTableScan"; 8546 [labelType="html" label="MapPartitionsRDD [8546] [Unordered] jdbc at <unknown>:0"]; 8547 [labelType="html" label="MapPartitionsRDD [8547] [Unordered] jdbc at <unknown>:0"]; 8548 [labelType="html" label="MapPartitionsRDD [8548] [Unordered] jdbc at <unknown>:0"]; } subgraph cluster19626 { label="Filter"; 8549 [labelType="html" label="MapPartitionsRDD [8549] [Unordered] jdbc at <unknown>:0"]; } subgraph cluster19625 { label="Project"; 8550 [labelType="html" label="MapPartitionsRDD [8550] [Unordered] jdbc at <unknown>:0"]; } subgraph cluster19620 { label="WholeStageCodegen (1)"; 8551 [labelType="html" label="MapPartitionsRDD [8551] [Unordered] jdbc at <unknown>:0"]; } subgraph cluster19619 { label="DeserializeToObject"; 8552 [labelType="html" label="MapPartitionsRDD [8552] [Unordered] jdbc at <unknown>:0"]; } subgraph cluster19629 { label="mapPartitions"; 8554 [labelType="html" label="MapPartitionsRDD [8554] [Unordered] jdbc at <unknown>:0"]; } } 8471->8472; 8472->8473; 8473->8474; 8474->8546; 8546->8547; 8547->8548; 8548->8549; 8549->8550; 8550->8551; 8551->8552; 8552->8553; 8553->8554; }

8465,8471

8474

Event Timeline

Enable zooming