DataHubScheduler - Details for Stage 26676 (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: 17912

digraph G { subgraph clusterstage_26676 { label="Stage 26676"; 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 cluster294662 { label="InMemoryTableScan"; 117588 [labelType="html" label="MapPartitionsRDD [117588] [Unordered] javaToPython at <unknown>:0"]; 117589 [labelType="html" label="MapPartitionsRDD [117589] [Unordered] javaToPython at <unknown>:0"]; 117590 [labelType="html" label="MapPartitionsRDD [117590] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster294656 { label="WholeStageCodegen (10)"; 117591 [labelType="html" label="MapPartitionsRDD [117591] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster294655 { label="SortAggregate"; 117592 [labelType="html" label="MapPartitionsRDD [117592] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster294654 { label="SortAggregate"; 117593 [labelType="html" label="MapPartitionsRDD [117593] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster294650 { label="WholeStageCodegen (11)"; 117594 [labelType="html" label="MapPartitionsRDD [117594] [Unordered] javaToPython at <unknown>:0"]; } subgraph cluster294649 { label="Exchange"; 117595 [labelType="html" label="MapPartitionsRDD [117595] [Unordered] javaToPython at <unknown>:0"]; } } 117253->117254; 117254->117255; 117255->117588; 117588->117589; 117589->117590; 117590->117591; 117591->117592; 117592->117593; 117593->117594; 117594->117595; }

117252,117253

117255

Event Timeline

Enable zooming