crp-order-quantity-kpi-service - Details for Stage 190436 (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 / 479444
Associated Job Ids: 52625

digraph G { id="graph_190436"; subgraph graph_stage_190436 { id="graph_stage_190436"; isCluster="true"; label="Stage 190436"; subgraph cluster_1108330 { id="cluster_1108330"; isCluster="true"; label="Exchange"; 424044 [id="node_424044" labelType="html" label="ShuffledRowRDD [424044] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108327 { id="cluster_1108327"; isCluster="true"; label="WholeStageCodegen (7)"; 424045 [id="node_424045" labelType="html" label="MapPartitionsRDD [424045] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108326 { id="cluster_1108326"; isCluster="true"; label="SortAggregate"; 424046 [id="node_424046" labelType="html" label="MapPartitionsRDD [424046] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108325 { id="cluster_1108325"; isCluster="true"; label="InMemoryTableScan"; 424047 [id="node_424047" labelType="html" label="MapPartitionsRDD [424047] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 424048 [id="node_424048" labelType="html" label="SortAggregate(key=[demandChannel#6839967, shardId#6552521, qty#6839987, worklistShardItemId#6552522L, demandStream#6839968], functions=[first(kpis#6839996, false)], output=[shardId#6552521, worklistShardItemId#6552522L, qty#6839987, demandChannel#6839967, demandStream#6839968, kpis#6840109])\n+- *(7) Sort [demandChannel#6839967 ASC NULLS FIRST, shardId#6552521 ASC NULLS FIRST, qty#6839987 ASC NULLS FIRST, worklistShardItemId#6552522L ASC NULLS FIRST, demandStream#6839968 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#6839967, shardId#6552521, qty#6839987, worklistShardItemId#6552522L, demandStream#6839968, 30), ENSURE_REQUIREMENTS, [plan_id=29055547]\n +- SortAggregate(key=[demandChannel#6839967, shardId#6552521, knownfloatingpointnormalized(normalizenanandzero(qty#6839987)) AS qty#6839987, worklistShardItemId#6552522L, demandStream#6839968], functions=[partial_first(kpis#6839996, false)], output=[demandChannel#6839967, shardId#6552521, qty#6839987, worklistShardItemId#6552522L... [424048] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108437 { id="cluster_1108437"; isCluster="true"; label="InMemoryTableScan"; 424055 [id="node_424055" labelType="html" label="MapPartitionsRDD [424055] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 424056 [id="node_424056" labelType="html" label="MapPartitionsRDD [424056] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 424057 [id="node_424057" labelType="html" label="MapPartitionsRDD [424057] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108434 { id="cluster_1108434"; isCluster="true"; label="WholeStageCodegen (1)"; 424058 [id="node_424058" labelType="html" label="MapPartitionsRDD [424058] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108433 { id="cluster_1108433"; isCluster="true"; label="Exchange"; 424059 [id="node_424059" labelType="html" label="MapPartitionsRDD [424059] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 424044->424045; 424045->424046; 424046->424047; 424047->424048; 424048->424055; 424055->424056; 424056->424057; 424057->424058; 424058->424059; }

424043,424044

424048

Event Timeline

Enable zooming