DataHubScheduler - Details for Stage 26770 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 0.1 s
Locality Level Summary: Process local: 2
Input Size / Records: 19.3 KiB / 2
Associated Job Ids: 17962

digraph G { subgraph clusterstage_26770 { label="Stage 26770"; subgraph cluster294752 { label="Exchange"; 117625 [labelType="html" label="ShuffledRowRDD [117625] [Unordered] count at <unknown>:0"]; } subgraph cluster294753 { label="mapPartitionsInternal"; 117626 [labelType="html" label="MapPartitionsRDD [117626] [Unordered] count at <unknown>:0"]; } subgraph cluster294754 { label="mapPartitionsInternal"; 117627 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Exchange SinglePartition, REPARTITION_BY_NUM, [plan_id=3993705]\n +- Project [brand_context_id#12010729, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, NetworkID#12010730, 64, true, false, true) AS NetworkID#12010773, Child_Node#12010731, Parent_id#12010732, supplier_id#12010733, preferrd_supplier_id#12010734, supplier_ref_id#12010735, supplier_uid#12010736, supplier_name#12010737, supplier_country#12010738, direct_indirect#12010739, source_type#12010740, product_name#12010741, tier#12010742, is_latest#12010743, is_latest_submitted#12010744, is_unknown_supplier#12010745, company_id#12010746, config_name#12010747, direct_supplier_name#12010748, launch_request_name#12010749, launch_config_ref#12010750, revision_version#12010751, submission_status#12010752, ... 23 more fields]\n +- Scan JDBCRelation((\nSELECT\n c.brand_context_id,\n c.NetworkID,\n c.Child_Node,\n c.Parent_id,\n ISNULL(c.supplier_i... [117627] [Cached] [Unordered] count at <unknown>:0"]; } subgraph cluster295508 { label="InMemoryTableScan"; 117924 [labelType="html" label="MapPartitionsRDD [117924] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 117925 [labelType="html" label="MapPartitionsRDD [117925] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 117926 [labelType="html" label="MapPartitionsRDD [117926] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster295487 { label="WholeStageCodegen (4)"; 117932 [labelType="html" label="MapPartitionsRDD [117932] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster295529 { label="InMemoryTableScan"; 117936 [labelType="html" label="MapPartitionsRDD [117936] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 117939 [labelType="html" label="MapPartitionsRDD [117939] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 117940 [labelType="html" label="MapPartitionsRDD [117940] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster295523 { label="WholeStageCodegen (5)"; 117941 [labelType="html" label="MapPartitionsRDD [117941] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster295522 { label="SortAggregate"; 117942 [labelType="html" label="MapPartitionsRDD [117942] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster295521 { label="SortAggregate"; 117943 [labelType="html" label="MapPartitionsRDD [117943] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster295518 { label="WholeStageCodegen (6)"; 117944 [labelType="html" label="MapPartitionsRDD [117944] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster295486 { label="Union"; 117945 [labelType="html" label="UnionRDD [117945] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster295484 { label="BroadcastExchange"; 117946 [labelType="html" label="MapPartitionsRDD [117946] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } } 117625->117626; 117626->117627; 117627->117924; 117924->117925; 117925->117926; 117926->117932; 117627->117936; 117936->117939; 117939->117940; 117940->117941; 117941->117942; 117942->117943; 117943->117944; 117932->117945; 117944->117945; 117945->117946; }

117624,117625

117627

Event Timeline

Enable zooming