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

Resource Profile Id: 0
Total Time Across All Tasks: 4 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: 52517

digraph G { id="graph_189892"; subgraph graph_stage_189892 { id="graph_stage_189892"; isCluster="true"; label="Stage 189892"; subgraph cluster_1104817 { id="cluster_1104817"; isCluster="true"; label="Exchange"; 422643 [id="node_422643" labelType="html" label="ShuffledRowRDD [422643] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104814 { id="cluster_1104814"; isCluster="true"; label="WholeStageCodegen (7)"; 422644 [id="node_422644" labelType="html" label="MapPartitionsRDD [422644] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104813 { id="cluster_1104813"; isCluster="true"; label="SortAggregate"; 422645 [id="node_422645" labelType="html" label="MapPartitionsRDD [422645] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104812 { id="cluster_1104812"; isCluster="true"; label="InMemoryTableScan"; 422646 [id="node_422646" labelType="html" label="MapPartitionsRDD [422646] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 422647 [id="node_422647" labelType="html" label="SortAggregate(key=[demandChannel#6818187, shardId#6552497, qty#6818207, worklistShardItemId#6552498L, demandStream#6818188], functions=[first(kpis#6818216, false)], output=[shardId#6552497, worklistShardItemId#6552498L, qty#6818207, demandChannel#6818187, demandStream#6818188, kpis#6818329])\n+- *(7) Sort [demandChannel#6818187 ASC NULLS FIRST, shardId#6552497 ASC NULLS FIRST, qty#6818207 ASC NULLS FIRST, worklistShardItemId#6552498L ASC NULLS FIRST, demandStream#6818188 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#6818187, shardId#6552497, qty#6818207, worklistShardItemId#6552498L, demandStream#6818188, 30), ENSURE_REQUIREMENTS, [plan_id=29046855]\n +- SortAggregate(key=[demandChannel#6818187, shardId#6552497, knownfloatingpointnormalized(normalizenanandzero(qty#6818207)) AS qty#6818207, worklistShardItemId#6552498L, demandStream#6818188], functions=[partial_first(kpis#6818216, false)], output=[demandChannel#6818187, shardId#6552497, qty#6818207, worklistShardItemId#6552498L... [422647] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104924 { id="cluster_1104924"; isCluster="true"; label="InMemoryTableScan"; 422654 [id="node_422654" labelType="html" label="MapPartitionsRDD [422654] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 422655 [id="node_422655" labelType="html" label="MapPartitionsRDD [422655] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 422656 [id="node_422656" labelType="html" label="MapPartitionsRDD [422656] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104921 { id="cluster_1104921"; isCluster="true"; label="WholeStageCodegen (1)"; 422657 [id="node_422657" labelType="html" label="MapPartitionsRDD [422657] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104920 { id="cluster_1104920"; isCluster="true"; label="Exchange"; 422658 [id="node_422658" labelType="html" label="MapPartitionsRDD [422658] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 422643->422644; 422644->422645; 422645->422646; 422646->422647; 422647->422654; 422654->422655; 422655->422656; 422656->422657; 422657->422658; }

422642,422643

422647

Event Timeline

Enable zooming