DataHubScheduler - Details for Stage 2458 (Attempt 0)

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

digraph G { subgraph clusterstage_2458 { label="Stage 2458"; 8696 [labelType="html" label="SQLExecutionRDD [8696] [Unordered] jdbc at <unknown>:0"]; subgraph cluster18632 { label="Exchange"; 8060 [labelType="html" label="ShuffledRowRDD [8060] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster18623 { label="WholeStageCodegen (3)"; 8061 [labelType="html" label="MapPartitionsRDD [8061] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster18235 { label="AdaptiveSparkPlan"; 8062 [labelType="html" label="MapPartitionsRDD [8062] [Unordered] javaToPython at <unknown>:0"]; 8063 [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#594888, summary__config_version#595024, summary__entity_id#595026, summary__submission_status#595028, summary__is_latest#595031, summary__is_editable#595035, summary__launch_date#595037, summary__expiry_date#595039, summary__submitted_date#595040, summary__create_ts#595041, summary__update_ts#595113, summary__create_date#595116, summary__update_date#595117, summary__source#595118, summary__recurrence_count#595119, summary__priority#595121, summary__remarks#595190, summary__latest_source#595194, summary__launch_request_name#595195, summary__NetworkID#595196, ... 49 more fields]\n +- BroadcastHashJoin [brand_context_id#584899, company_id#584900, launch_config_ref#584901, revision_version#584902], [brand_context_id#588012, company_id#588013, launch_config_ref#588014, revision_version#588015], Inner, BuildLeft, false\n :- BroadcastExchange Hash... [8063] [Cached] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster19930 { label="InMemoryTableScan"; 8689 [labelType="html" label="MapPartitionsRDD [8689] [Unordered] jdbc at <unknown>:0"]; 8690 [labelType="html" label="MapPartitionsRDD [8690] [Unordered] jdbc at <unknown>:0"]; 8691 [labelType="html" label="MapPartitionsRDD [8691] [Unordered] jdbc at <unknown>:0"]; } subgraph cluster19928 { label="Filter"; 8692 [labelType="html" label="MapPartitionsRDD [8692] [Unordered] jdbc at <unknown>:0"]; } subgraph cluster19927 { label="Project"; 8693 [labelType="html" label="MapPartitionsRDD [8693] [Unordered] jdbc at <unknown>:0"]; } subgraph cluster19922 { label="WholeStageCodegen (1)"; 8694 [labelType="html" label="MapPartitionsRDD [8694] [Unordered] jdbc at <unknown>:0"]; } subgraph cluster19921 { label="DeserializeToObject"; 8695 [labelType="html" label="MapPartitionsRDD [8695] [Unordered] jdbc at <unknown>:0"]; } subgraph cluster19931 { label="mapPartitions"; 8697 [labelType="html" label="MapPartitionsRDD [8697] [Unordered] jdbc at <unknown>:0"]; } } 8060->8061; 8061->8062; 8062->8063; 8063->8689; 8689->8690; 8690->8691; 8691->8692; 8692->8693; 8693->8694; 8694->8695; 8695->8696; 8696->8697; }

7888,8060

8063

Event Timeline

Enable zooming