DataHubScheduler - Details for Stage 2544 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 10 ms
Locality Level Summary: Process local: 5
Input Size / Records: 40.9 KiB / 2
Associated Job Ids: 1981

digraph G { subgraph clusterstage_2544 { label="Stage 2544"; subgraph cluster20454 { label="Exchange"; 8933 [labelType="html" label="ShuffledRowRDD [8933] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster20445 { label="WholeStageCodegen (3)"; 8935 [labelType="html" label="MapPartitionsRDD [8935] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster20244 { label="AdaptiveSparkPlan"; 8936 [labelType="html" label="MapPartitionsRDD [8936] [Unordered] javaToPython at <unknown>:0"]; 8937 [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#759145, summary__config_version#759146, summary__entity_id#759147, summary__submission_status#759148, summary__is_latest#759149, summary__is_editable#759150, summary__launch_date#759151, summary__expiry_date#759152, summary__submitted_date#759153, summary__create_ts#759154, summary__update_ts#759155, summary__create_date#759156, summary__update_date#759157, summary__source#759158, summary__recurrence_count#759159, summary__priority#759160, summary__remarks#759161, summary__latest_source#759162, summary__launch_request_name#759163, summary__NetworkID#759164, ... 49 more fields]\n +- BroadcastHashJoin [brand_context_id#584899, company_id#584900, launch_config_ref#584901, revision_version#584902], [brand_context_id#753747, company_id#753748, launch_config_ref#753749, revision_version#753750], Inner, BuildLeft, false\n :- BroadcastExchange Hash... [8937] [Cached] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster20689 { label="InMemoryTableScan"; 9047 [labelType="html" label="MapPartitionsRDD [9047] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 9048 [labelType="html" label="MapPartitionsRDD [9048] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 9049 [labelType="html" label="MapPartitionsRDD [9049] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster20684 { label="WholeStageCodegen (1)"; 9050 [labelType="html" label="MapPartitionsRDD [9050] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster20683 { label="BroadcastExchange"; 9051 [labelType="html" label="MapPartitionsRDD [9051] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } } 8933->8935; 8935->8936; 8936->8937; 8937->9047; 9047->9048; 9048->9049; 9049->9050; 9050->9051; }

8841,8933

8937

Event Timeline

Enable zooming