DataHubScheduler - Details for Stage 26672 (Attempt 0)

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

digraph G { subgraph clusterstage_26672 { label="Stage 26672"; subgraph cluster293835 { label="Exchange"; 117253 [labelType="html" label="ShuffledRowRDD [117253] [Unordered] count at <unknown>:0"]; } subgraph cluster293836 { label="mapPartitionsInternal"; 117254 [labelType="html" label="MapPartitionsRDD [117254] [Unordered] count at <unknown>:0"]; } subgraph cluster293837 { label="mapPartitionsInternal"; 117255 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Exchange hashpartitioning(NetworkID#11981894, 2), REPARTITION_BY_NUM, [plan_id=3989029]\n +- Project [brand_context_id#11981850, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, NetworkID#11981851, 64, true, false, true) AS NetworkID#11981894, Child_Node#11981852, Parent_id#11981853, supplier_id#11981854, preferrd_supplier_id#11981855, supplier_ref_id#11981856, supplier_uid#11981857, supplier_name#11981858, supplier_country#11981859, direct_indirect#11981860, source_type#11981861, product_name#11981862, tier#11981863, is_latest#11981864, is_latest_submitted#11981865, is_unknown_supplier#11981866, company_id#11981867, config_name#11981868, direct_supplier_name#11981869, launch_request_name#11981870, launch_config_ref#11981871, revision_version#11981872, submission_status#11981873, ... 23 more fields]\n +- Scan JDBCRelation((\nSELECT\n c.brand_context_id,\n c.NetworkID,\n c.Child_Node,\n c.Parent_id,... [117255] [Cached] [Unordered] count at <unknown>:0"]; } subgraph cluster294611 { label="InMemoryTableScan"; 117547 [labelType="html" label="MapPartitionsRDD [117547] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 117548 [labelType="html" label="MapPartitionsRDD [117548] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 117550 [labelType="html" label="MapPartitionsRDD [117550] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster294603 { label="WholeStageCodegen (7)"; 117557 [labelType="html" label="MapPartitionsRDD [117557] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster294602 { label="SortAggregate"; 117559 [labelType="html" label="MapPartitionsRDD [117559] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster294600 { label="SortAggregate"; 117560 [labelType="html" label="MapPartitionsRDD [117560] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster294591 { label="BroadcastExchange"; 117561 [labelType="html" label="MapPartitionsRDD [117561] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } } 117253->117254; 117254->117255; 117255->117547; 117547->117548; 117548->117550; 117550->117557; 117557->117559; 117559->117560; 117560->117561; }

117252,117253

117255

Event Timeline

Enable zooming