DataHubScheduler - Details for Stage 2512 (Attempt 0)

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

digraph G { subgraph clusterstage_2512 { label="Stage 2512"; 8931 [labelType="html" label="SQLExecutionRDD [8931] [Unordered] jdbc at <unknown>:0"]; subgraph cluster20104 { label="Exchange"; 8767 [labelType="html" label="ShuffledRowRDD [8767] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster20095 { label="WholeStageCodegen (3)"; 8768 [labelType="html" label="MapPartitionsRDD [8768] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster20022 { label="AdaptiveSparkPlan"; 8769 [labelType="html" label="MapPartitionsRDD [8769] [Unordered] 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] javaToPython at <unknown>:0"]; } subgraph cluster20442 { label="InMemoryTableScan"; 8924 [labelType="html" label="MapPartitionsRDD [8924] [Unordered] jdbc at <unknown>:0"]; 8925 [labelType="html" label="MapPartitionsRDD [8925] [Unordered] jdbc at <unknown>:0"]; 8926 [labelType="html" label="MapPartitionsRDD [8926] [Unordered] jdbc at <unknown>:0"]; } subgraph cluster20440 { label="Filter"; 8927 [labelType="html" label="MapPartitionsRDD [8927] [Unordered] jdbc at <unknown>:0"]; } subgraph cluster20439 { label="Project"; 8928 [labelType="html" label="MapPartitionsRDD [8928] [Unordered] jdbc at <unknown>:0"]; } subgraph cluster20434 { label="WholeStageCodegen (1)"; 8929 [labelType="html" label="MapPartitionsRDD [8929] [Unordered] jdbc at <unknown>:0"]; } subgraph cluster20433 { label="DeserializeToObject"; 8930 [labelType="html" label="MapPartitionsRDD [8930] [Unordered] jdbc at <unknown>:0"]; } subgraph cluster20443 { label="mapPartitions"; 8932 [labelType="html" label="MapPartitionsRDD [8932] [Unordered] jdbc at <unknown>:0"]; } } 8767->8768; 8768->8769; 8769->8770; 8770->8924; 8924->8925; 8925->8926; 8926->8927; 8927->8928; 8928->8929; 8929->8930; 8930->8931; 8931->8932; }

8745,8767

8770

Event Timeline

Enable zooming