DataHubScheduler - Details for Stage 39725 (Attempt 0)

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

digraph G { subgraph clusterstage_39725 { label="Stage 39725"; subgraph cluster403976 { label="Exchange"; 169602 [labelType="html" label="ShuffledRowRDD [169602] [Unordered] count at <unknown>:0"]; } subgraph cluster403977 { label="mapPartitionsInternal"; 169603 [labelType="html" label="MapPartitionsRDD [169603] [Unordered] count at <unknown>:0"]; } subgraph cluster403978 { label="mapPartitionsInternal"; 169604 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Exchange SinglePartition, REPARTITION_BY_NUM, [plan_id=3316740]\n +- Project [brand_context_id#20322450, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, NetworkID#20322451, 64, true, false, true) AS NetworkID#20322494, Child_Node#20322452, Parent_id#20322453, supplier_id#20322454, preferrd_supplier_id#20322455, supplier_ref_id#20322456, supplier_uid#20322457, supplier_name#20322458, supplier_country#20322459, direct_indirect#20322460, source_type#20322461, product_name#20322462, tier#20322463, is_latest#20322464, is_latest_submitted#20322465, is_unknown_supplier#20322466, company_id#20322467, config_name#20322468, direct_supplier_name#20322469, launch_request_name#20322470, launch_config_ref#20322471, revision_version#20322472, submission_status#20322473, ... 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... [169604] [Cached] [Unordered] count at <unknown>:0"]; } subgraph cluster405366 { label="InMemoryTableScan"; 170141 [labelType="html" label="MapPartitionsRDD [170141] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 170142 [labelType="html" label="MapPartitionsRDD [170142] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 170144 [labelType="html" label="MapPartitionsRDD [170144] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster405345 { label="WholeStageCodegen (1)"; 170149 [labelType="html" label="MapPartitionsRDD [170149] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster405390 { label="InMemoryTableScan"; 170167 [labelType="html" label="MapPartitionsRDD [170167] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 170168 [labelType="html" label="MapPartitionsRDD [170168] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 170169 [labelType="html" label="MapPartitionsRDD [170169] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster405377 { label="WholeStageCodegen (2)"; 170170 [labelType="html" label="MapPartitionsRDD [170170] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster405376 { label="SortAggregate"; 170171 [labelType="html" label="MapPartitionsRDD [170171] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster405375 { label="SortAggregate"; 170172 [labelType="html" label="MapPartitionsRDD [170172] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster405369 { label="WholeStageCodegen (3)"; 170173 [labelType="html" label="MapPartitionsRDD [170173] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster405344 { label="Union"; 170174 [labelType="html" label="UnionRDD [170174] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster405342 { label="BroadcastExchange"; 170175 [labelType="html" label="MapPartitionsRDD [170175] [Unordered] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } } 169602->169603; 169603->169604; 169604->170141; 170141->170142; 170142->170144; 170144->170149; 169604->170167; 170167->170168; 170168->170169; 170169->170170; 170170->170171; 170171->170172; 170172->170173; 170149->170174; 170173->170174; 170174->170175; }

169599,169602

169604

Event Timeline

Enable zooming