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

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 30
Input Size / Records: 8.9 MiB / 90
Shuffle Write Size / Records: 8.7 MiB / 476584
Associated Job Ids: 52712

digraph G { id="graph_190842"; subgraph graph_stage_190842 { id="graph_stage_190842"; isCluster="true"; label="Stage 190842"; subgraph cluster_1111005 { id="cluster_1111005"; isCluster="true"; label="Exchange"; 425146 [id="node_425146" labelType="html" label="ShuffledRowRDD [425146] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111002 { id="cluster_1111002"; isCluster="true"; label="WholeStageCodegen (7)"; 425147 [id="node_425147" labelType="html" label="MapPartitionsRDD [425147] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111001 { id="cluster_1111001"; isCluster="true"; label="SortAggregate"; 425148 [id="node_425148" labelType="html" label="MapPartitionsRDD [425148] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111000 { id="cluster_1111000"; isCluster="true"; label="InMemoryTableScan"; 425149 [id="node_425149" labelType="html" label="MapPartitionsRDD [425149] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425150 [id="node_425150" labelType="html" label="SortAggregate(key=[demandChannel#6857293, shardId#6552497, qty#6857313, worklistShardItemId#6552498L, demandStream#6857294], functions=[first(kpis#6857322, false)], output=[shardId#6552497, worklistShardItemId#6552498L, qty#6857313, demandChannel#6857293, demandStream#6857294, kpis#6857435])\n+- *(7) Sort [demandChannel#6857293 ASC NULLS FIRST, shardId#6552497 ASC NULLS FIRST, qty#6857313 ASC NULLS FIRST, worklistShardItemId#6552498L ASC NULLS FIRST, demandStream#6857294 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#6857293, shardId#6552497, qty#6857313, worklistShardItemId#6552498L, demandStream#6857294, 30), ENSURE_REQUIREMENTS, [plan_id=29062235]\n +- SortAggregate(key=[demandChannel#6857293, shardId#6552497, knownfloatingpointnormalized(normalizenanandzero(qty#6857313)) AS qty#6857313, worklistShardItemId#6552498L, demandStream#6857294], functions=[partial_first(kpis#6857322, false)], output=[demandChannel#6857293, shardId#6552497, qty#6857313, worklistShardItemId#6552498L... [425150] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111148 { id="cluster_1111148"; isCluster="true"; label="InMemoryTableScan"; 425170 [id="node_425170" labelType="html" label="MapPartitionsRDD [425170] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425171 [id="node_425171" labelType="html" label="MapPartitionsRDD [425171] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425172 [id="node_425172" labelType="html" label="MapPartitionsRDD [425172] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111145 { id="cluster_1111145"; isCluster="true"; label="WholeStageCodegen (1)"; 425173 [id="node_425173" labelType="html" label="MapPartitionsRDD [425173] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111144 { id="cluster_1111144"; isCluster="true"; label="Exchange"; 425174 [id="node_425174" labelType="html" label="MapPartitionsRDD [425174] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 425146->425147; 425147->425148; 425148->425149; 425149->425150; 425150->425170; 425170->425171; 425171->425172; 425172->425173; 425173->425174; }

425145,425146

425150

Event Timeline

Enable zooming