DataHubScheduler - Details for Stage 26674 (Attempt 0)

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

digraph G { subgraph clusterstage_26674 { label="Stage 26674"; 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 cluster294648 { label="InMemoryTableScan"; 117580 [labelType="html" label="MapPartitionsRDD [117580] [Unordered] javaToPython at <unknown>:0"]; 117581 [labelType="html" label="MapPartitionsRDD [117581] [Unordered] javaToPython at <unknown>:0"]; 117582 [labelType="html" label="MapPartitionsRDD [117582] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster294642 { label="WholeStageCodegen (8)"; 117583 [labelType="html" label="MapPartitionsRDD [117583] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster294641 { label="SortAggregate"; 117584 [labelType="html" label="MapPartitionsRDD [117584] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster294640 { label="SortAggregate"; 117585 [labelType="html" label="MapPartitionsRDD [117585] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster294599 { label="WholeStageCodegen (9)"; 117586 [labelType="html" label="MapPartitionsRDD [117586] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster294598 { label="Exchange"; 117587 [labelType="html" label="MapPartitionsRDD [117587] [Unordered] javaToPython at <unknown>:0"]; } } 117253->117254; 117254->117255; 117255->117580; 117580->117581; 117581->117582; 117582->117583; 117583->117584; 117584->117585; 117585->117586; 117586->117587; }

117252,117253

117255

Event Timeline

Enable zooming