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

Resource Profile Id: 0
Total Time Across All Tasks: 3 s
Locality Level Summary: Process local: 30
Input Size / Records: 7.7 MiB / 90
Shuffle Write Size / Records: 7.4 MiB / 410552
Associated Job Ids: 66501

digraph G { id="graph_241611"; subgraph graph_stage_241611 { id="graph_stage_241611"; isCluster="true"; label="Stage 241611"; subgraph cluster_1412196 { id="cluster_1412196"; isCluster="true"; label="Exchange"; 540782 [id="node_540782" labelType="html" label="ShuffledRowRDD [540782] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412193 { id="cluster_1412193"; isCluster="true"; label="WholeStageCodegen (7)"; 540783 [id="node_540783" labelType="html" label="MapPartitionsRDD [540783] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412192 { id="cluster_1412192"; isCluster="true"; label="SortAggregate"; 540784 [id="node_540784" labelType="html" label="MapPartitionsRDD [540784] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412191 { id="cluster_1412191"; isCluster="true"; label="InMemoryTableScan"; 540785 [id="node_540785" labelType="html" label="MapPartitionsRDD [540785] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540786 [id="node_540786" labelType="html" label="SortAggregate(key=[demandChannel#8718905, shardId#8398780, qty#8718925, worklistShardItemId#8398781L, demandStream#8718906], functions=[first(kpis#8718934, false)], output=[shardId#8398780, worklistShardItemId#8398781L, qty#8718925, demandChannel#8718905, demandStream#8718906, kpis#8719047])\n+- *(7) Sort [demandChannel#8718905 ASC NULLS FIRST, shardId#8398780 ASC NULLS FIRST, qty#8718925 ASC NULLS FIRST, worklistShardItemId#8398781L ASC NULLS FIRST, demandStream#8718906 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#8718905, shardId#8398780, qty#8718925, worklistShardItemId#8398781L, demandStream#8718906, 30), ENSURE_REQUIREMENTS, [plan_id=36548095]\n +- SortAggregate(key=[demandChannel#8718905, shardId#8398780, knownfloatingpointnormalized(normalizenanandzero(qty#8718925)) AS qty#8718925, worklistShardItemId#8398781L, demandStream#8718906], functions=[partial_first(kpis#8718934, false)], output=[demandChannel#8718905, shardId#8398780, qty#8718925, worklistShardItemId#8398781L... [540786] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412303 { id="cluster_1412303"; isCluster="true"; label="InMemoryTableScan"; 540793 [id="node_540793" labelType="html" label="MapPartitionsRDD [540793] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540794 [id="node_540794" labelType="html" label="MapPartitionsRDD [540794] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540795 [id="node_540795" labelType="html" label="MapPartitionsRDD [540795] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412300 { id="cluster_1412300"; isCluster="true"; label="WholeStageCodegen (1)"; 540796 [id="node_540796" labelType="html" label="MapPartitionsRDD [540796] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412299 { id="cluster_1412299"; isCluster="true"; label="Exchange"; 540797 [id="node_540797" labelType="html" label="MapPartitionsRDD [540797] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 540782->540783; 540783->540784; 540784->540785; 540785->540786; 540786->540793; 540793->540794; 540794->540795; 540795->540796; 540796->540797; }

540781,540782

540786

Event Timeline

Enable zooming