crp-order-quantity-kpi-service - Details for Stage 104362 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 37
Input Size / Records: 20.3 KiB / 33
Shuffle Write Size / Records: 3.0 KiB / 33
Associated Job Ids: 5762

digraph G { id="graph_104362"; subgraph graph_stage_104362 { id="graph_stage_104362"; isCluster="true"; label="Stage 104362"; subgraph cluster_130654 { id="cluster_130654"; isCluster="true"; label="Exchange"; 50117 [id="node_50117" labelType="html" label="ShuffledRowRDD [50117] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130648 { id="cluster_130648"; isCluster="true"; label="WholeStageCodegen (6)"; 50118 [id="node_50118" labelType="html" label="MapPartitionsRDD [50118] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130647 { id="cluster_130647"; isCluster="true"; label="SortAggregate"; 50119 [id="node_50119" labelType="html" label="MapPartitionsRDD [50119] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130646 { id="cluster_130646"; isCluster="true"; label="InMemoryTableScan"; 50120 [id="node_50120" labelType="html" label="MapPartitionsRDD [50120] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 50121 [id="node_50121" labelType="html" label="SortAggregate(key=[demandChannel#1003752, shardId#943631, qty#1003772, worklistShardItemId#943632L, demandStream#1003753], functions=[first(kpis#1003781, false)], output=[shardId#943631, worklistShardItemId#943632L, qty#1003772, demandChannel#1003752, demandStream#1003753, kpis#1003914])\n+- *(6) Sort [demandChannel#1003752 ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST, qty#1003772 ASC NULLS FIRST, worklistShardItemId#943632L ASC NULLS FIRST, demandStream#1003753 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1003752, shardId#943631, qty#1003772, worklistShardItemId#943632L, demandStream#1003753, 37), ENSURE_REQUIREMENTS, [plan_id=1631410]\n +- SortAggregate(key=[demandChannel#1003752, shardId#943631, knownfloatingpointnormalized(normalizenanandzero(qty#1003772)) AS qty#1003772, worklistShardItemId#943632L, demandStream#1003753], functions=[partial_first(kpis#1003781, false)], output=[demandChannel#1003752, shardId#943631, qty#1003772, worklistShardItemId#943632L, demandStrea... [50121] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130749 { id="cluster_130749"; isCluster="true"; label="InMemoryTableScan"; 50134 [id="node_50134" labelType="html" label="MapPartitionsRDD [50134] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 50135 [id="node_50135" labelType="html" label="MapPartitionsRDD [50135] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 50136 [id="node_50136" labelType="html" label="MapPartitionsRDD [50136] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130746 { id="cluster_130746"; isCluster="true"; label="WholeStageCodegen (1)"; 50137 [id="node_50137" labelType="html" label="MapPartitionsRDD [50137] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130745 { id="cluster_130745"; isCluster="true"; label="Exchange"; 50138 [id="node_50138" labelType="html" label="MapPartitionsRDD [50138] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 50117->50118; 50118->50119; 50119->50120; 50120->50121; 50121->50134; 50134->50135; 50135->50136; 50136->50137; 50137->50138; }

50116,50117

50121

50117

50118

50119

50120

50121

50134

50135

50136

50137

50138

Event Timeline

Enable zooming