DataHubScheduler - Details for Stage 34079 (Attempt 0)

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

digraph G { subgraph clusterstage_34079 { label="Stage 34079"; subgraph cluster361485 { label="Exchange"; 149637 [labelType="html" label="ShuffledRowRDD [149637] [Unordered] count at <unknown>:0"]; } subgraph cluster361486 { label="mapPartitionsInternal"; 149638 [labelType="html" label="MapPartitionsRDD [149638] [Unordered] count at <unknown>:0"]; } subgraph cluster361487 { label="mapPartitionsInternal"; 149639 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Exchange SinglePartition, REPARTITION_BY_NUM, [plan_id=4247782]\n +- Project [brand_context_id#14300060, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, NetworkID#14300061, 64, true, false, true) AS NetworkID#14300104, Child_Node#14300062, Parent_id#14300063, supplier_id#14300064, preferrd_supplier_id#14300065, supplier_ref_id#14300066, supplier_uid#14300067, supplier_name#14300068, supplier_country#14300069, direct_indirect#14300070, source_type#14300071, product_name#14300072, tier#14300073, is_latest#14300074, is_latest_submitted#14300075, is_unknown_supplier#14300076, company_id#14300077, config_name#14300078, direct_supplier_name#14300079, launch_request_name#14300080, launch_config_ref#14300081, revision_version#14300082, submission_status#14300083, ... 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... [149639] [Cached] [Unordered] count at <unknown>:0"]; } subgraph cluster362204 { label="InMemoryTableScan"; 149919 [labelType="html" label="MapPartitionsRDD [149919] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 149921 [labelType="html" label="MapPartitionsRDD [149921] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 149922 [labelType="html" label="MapPartitionsRDD [149922] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster362188 { label="WholeStageCodegen (4)"; 149924 [labelType="html" label="MapPartitionsRDD [149924] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster362228 { label="InMemoryTableScan"; 149928 [labelType="html" label="MapPartitionsRDD [149928] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 149929 [labelType="html" label="MapPartitionsRDD [149929] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 149930 [labelType="html" label="MapPartitionsRDD [149930] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster362220 { label="WholeStageCodegen (5)"; 149937 [labelType="html" label="MapPartitionsRDD [149937] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster362219 { label="SortAggregate"; 149938 [labelType="html" label="MapPartitionsRDD [149938] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster362218 { label="SortAggregate"; 149939 [labelType="html" label="MapPartitionsRDD [149939] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster362208 { label="WholeStageCodegen (6)"; 149940 [labelType="html" label="MapPartitionsRDD [149940] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster362187 { label="Union"; 149941 [labelType="html" label="UnionRDD [149941] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster362180 { label="BroadcastExchange"; 149942 [labelType="html" label="MapPartitionsRDD [149942] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } } 149637->149638; 149638->149639; 149639->149919; 149919->149921; 149921->149922; 149922->149924; 149639->149928; 149928->149929; 149929->149930; 149930->149937; 149937->149938; 149938->149939; 149939->149940; 149924->149941; 149940->149941; 149941->149942; }

149636,149637

149639

Event Timeline

Enable zooming