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

Resource Profile Id: 0
Total Time Across All Tasks: 6 s
Locality Level Summary: Process local: 30
Input Size / Records: 8.9 MiB / 90
Shuffle Write Size / Records: 8.8 MiB / 479444
Associated Job Ids: 52811

digraph G { id="graph_191322"; subgraph graph_stage_191322 { id="graph_stage_191322"; isCluster="true"; label="Stage 191322"; subgraph cluster_1114279 { id="cluster_1114279"; isCluster="true"; label="Exchange"; 426461 [id="node_426461" labelType="html" label="ShuffledRowRDD [426461] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114276 { id="cluster_1114276"; isCluster="true"; label="WholeStageCodegen (7)"; 426462 [id="node_426462" labelType="html" label="MapPartitionsRDD [426462] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114275 { id="cluster_1114275"; isCluster="true"; label="SortAggregate"; 426463 [id="node_426463" labelType="html" label="MapPartitionsRDD [426463] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114274 { id="cluster_1114274"; isCluster="true"; label="InMemoryTableScan"; 426464 [id="node_426464" labelType="html" label="MapPartitionsRDD [426464] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426465 [id="node_426465" labelType="html" label="SortAggregate(key=[demandChannel#6877355, shardId#6552521, qty#6877375, worklistShardItemId#6552522L, demandStream#6877356], functions=[first(kpis#6877384, false)], output=[shardId#6552521, worklistShardItemId#6552522L, qty#6877375, demandChannel#6877355, demandStream#6877356, kpis#6877497])\n+- *(7) Sort [demandChannel#6877355 ASC NULLS FIRST, shardId#6552521 ASC NULLS FIRST, qty#6877375 ASC NULLS FIRST, worklistShardItemId#6552522L ASC NULLS FIRST, demandStream#6877356 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#6877355, shardId#6552521, qty#6877375, worklistShardItemId#6552522L, demandStream#6877356, 30), ENSURE_REQUIREMENTS, [plan_id=29070493]\n +- SortAggregate(key=[demandChannel#6877355, shardId#6552521, knownfloatingpointnormalized(normalizenanandzero(qty#6877375)) AS qty#6877375, worklistShardItemId#6552522L, demandStream#6877356], functions=[partial_first(kpis#6877384, false)], output=[demandChannel#6877355, shardId#6552521, qty#6877375, worklistShardItemId#6552522L... [426465] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114386 { id="cluster_1114386"; isCluster="true"; label="InMemoryTableScan"; 426472 [id="node_426472" labelType="html" label="MapPartitionsRDD [426472] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426473 [id="node_426473" labelType="html" label="MapPartitionsRDD [426473] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426474 [id="node_426474" labelType="html" label="MapPartitionsRDD [426474] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114383 { id="cluster_1114383"; isCluster="true"; label="WholeStageCodegen (1)"; 426475 [id="node_426475" labelType="html" label="MapPartitionsRDD [426475] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114382 { id="cluster_1114382"; isCluster="true"; label="Exchange"; 426476 [id="node_426476" labelType="html" label="MapPartitionsRDD [426476] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 426461->426462; 426462->426463; 426463->426464; 426464->426465; 426465->426472; 426472->426473; 426473->426474; 426474->426475; 426475->426476; }

426460,426461

426465

Event Timeline

Enable zooming