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

Resource Profile Id: 0
Total Time Across All Tasks: 4 s
Locality Level Summary: Process local: 37
Input Size / Records: 23.8 KiB / 36
Shuffle Write Size / Records: 3.2 KiB / 36
Associated Job Ids: 5741

digraph G { id="graph_103632"; subgraph graph_stage_103632 { id="graph_stage_103632"; isCluster="true"; label="Stage 103632"; subgraph cluster_130032 { id="cluster_130032"; isCluster="true"; label="Exchange"; 49853 [id="node_49853" labelType="html" label="ShuffledRowRDD [49853] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130027 { id="cluster_130027"; isCluster="true"; label="WholeStageCodegen (6)"; 49854 [id="node_49854" labelType="html" label="MapPartitionsRDD [49854] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130026 { id="cluster_130026"; isCluster="true"; label="SortAggregate"; 49855 [id="node_49855" labelType="html" label="MapPartitionsRDD [49855] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130025 { id="cluster_130025"; isCluster="true"; label="InMemoryTableScan"; 49856 [id="node_49856" labelType="html" label="MapPartitionsRDD [49856] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 49857 [id="node_49857" labelType="html" label="SortAggregate(key=[demandChannel#998194, shardId#943631, qty#998214, worklistShardItemId#943632L, demandStream#998195], functions=[first(kpis#998223, false)], output=[shardId#943631, worklistShardItemId#943632L, qty#998214, demandChannel#998194, demandStream#998195, kpis#998356])\n+- *(6) Sort [demandChannel#998194 ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST, qty#998214 ASC NULLS FIRST, worklistShardItemId#943632L ASC NULLS FIRST, demandStream#998195 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#998194, shardId#943631, qty#998214, worklistShardItemId#943632L, demandStream#998195, 37), ENSURE_REQUIREMENTS, [plan_id=1629820]\n +- SortAggregate(key=[demandChannel#998194, shardId#943631, knownfloatingpointnormalized(normalizenanandzero(qty#998214)) AS qty#998214, worklistShardItemId#943632L, demandStream#998195], functions=[partial_first(kpis#998223, false)], output=[demandChannel#998194, shardId#943631, qty#998214, worklistShardItemId#943632L, demandStream#998195, first#99843... [49857] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130128 { id="cluster_130128"; isCluster="true"; label="InMemoryTableScan"; 49870 [id="node_49870" labelType="html" label="MapPartitionsRDD [49870] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 49871 [id="node_49871" labelType="html" label="MapPartitionsRDD [49871] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 49872 [id="node_49872" labelType="html" label="MapPartitionsRDD [49872] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130125 { id="cluster_130125"; isCluster="true"; label="WholeStageCodegen (1)"; 49873 [id="node_49873" labelType="html" label="MapPartitionsRDD [49873] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130124 { id="cluster_130124"; isCluster="true"; label="Exchange"; 49874 [id="node_49874" labelType="html" label="MapPartitionsRDD [49874] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 49853->49854; 49854->49855; 49855->49856; 49856->49857; 49857->49870; 49870->49871; 49871->49872; 49872->49873; 49873->49874; }

49852,49853

49857

49853

49854

49855

49856

49857

49870

49871

49872

49873

49874

Event Timeline

Enable zooming