DataHubScheduler - Details for Stage 39830 (Attempt 0)

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

digraph G { subgraph clusterstage_39830 { label="Stage 39830"; subgraph cluster405718 { label="Exchange"; 170287 [labelType="html" label="ShuffledRowRDD [170287] [Unordered] count at <unknown>:0"]; } subgraph cluster405719 { label="mapPartitionsInternal"; 170288 [labelType="html" label="MapPartitionsRDD [170288] [Unordered] count at <unknown>:0"]; } subgraph cluster405720 { label="mapPartitionsInternal"; 170289 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Exchange SinglePartition, REPARTITION_BY_NUM, [plan_id=3325998]\n +- Project [brand_context_id#20377588, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, NetworkID#20377589, 64, true, false, true) AS NetworkID#20377632, Child_Node#20377590, Parent_id#20377591, supplier_id#20377592, preferrd_supplier_id#20377593, supplier_ref_id#20377594, supplier_uid#20377595, supplier_name#20377596, supplier_country#20377597, direct_indirect#20377598, source_type#20377599, product_name#20377600, tier#20377601, is_latest#20377602, is_latest_submitted#20377603, is_unknown_supplier#20377604, company_id#20377605, config_name#20377606, direct_supplier_name#20377607, launch_request_name#20377608, launch_config_ref#20377609, revision_version#20377610, submission_status#20377611, ... 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... [170289] [Cached] [Unordered] count at <unknown>:0"]; } subgraph cluster406433 { label="InMemoryTableScan"; 170569 [labelType="html" label="MapPartitionsRDD [170569] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 170570 [labelType="html" label="MapPartitionsRDD [170570] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 170571 [labelType="html" label="MapPartitionsRDD [170571] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster406417 { label="WholeStageCodegen (4)"; 170573 [labelType="html" label="MapPartitionsRDD [170573] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster406457 { label="InMemoryTableScan"; 170581 [labelType="html" label="MapPartitionsRDD [170581] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 170582 [labelType="html" label="MapPartitionsRDD [170582] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 170583 [labelType="html" label="MapPartitionsRDD [170583] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster406449 { label="WholeStageCodegen (5)"; 170587 [labelType="html" label="MapPartitionsRDD [170587] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster406448 { label="SortAggregate"; 170588 [labelType="html" label="MapPartitionsRDD [170588] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster406447 { label="SortAggregate"; 170589 [labelType="html" label="MapPartitionsRDD [170589] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster406437 { label="WholeStageCodegen (6)"; 170593 [labelType="html" label="MapPartitionsRDD [170593] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster406416 { label="Union"; 170594 [labelType="html" label="UnionRDD [170594] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster406409 { label="BroadcastExchange"; 170595 [labelType="html" label="MapPartitionsRDD [170595] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } } 170287->170288; 170288->170289; 170289->170569; 170569->170570; 170570->170571; 170571->170573; 170289->170581; 170581->170582; 170582->170583; 170583->170587; 170587->170588; 170588->170589; 170589->170593; 170573->170594; 170593->170594; 170594->170595; }

170286,170287

170289

Event Timeline

Enable zooming