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

Resource Profile Id: 0
Total Time Across All Tasks: 5 s
Locality Level Summary: Process local: 30
Input Size / Records: 8.8 MiB / 90
Shuffle Write Size / Records: 8.6 MiB / 475632
Associated Job Ids: 52549

digraph G { id="graph_190059"; subgraph graph_stage_190059 { id="graph_stage_190059"; isCluster="true"; label="Stage 190059"; subgraph cluster_1105776 { id="cluster_1105776"; isCluster="true"; label="Exchange"; 423017 [id="node_423017" labelType="html" label="ShuffledRowRDD [423017] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1105773 { id="cluster_1105773"; isCluster="true"; label="WholeStageCodegen (7)"; 423018 [id="node_423018" labelType="html" label="MapPartitionsRDD [423018] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1105772 { id="cluster_1105772"; isCluster="true"; label="SortAggregate"; 423019 [id="node_423019" labelType="html" label="MapPartitionsRDD [423019] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1105771 { id="cluster_1105771"; isCluster="true"; label="InMemoryTableScan"; 423020 [id="node_423020" labelType="html" label="MapPartitionsRDD [423020] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 423021 [id="node_423021" labelType="html" label="SortAggregate(key=[demandChannel#6823929, shardId#6552521, qty#6823949, worklistShardItemId#6552522L, demandStream#6823930], functions=[first(kpis#6823958, false)], output=[shardId#6552521, worklistShardItemId#6552522L, qty#6823949, demandChannel#6823929, demandStream#6823930, kpis#6824071])\n+- *(7) Sort [demandChannel#6823929 ASC NULLS FIRST, shardId#6552521 ASC NULLS FIRST, qty#6823949 ASC NULLS FIRST, worklistShardItemId#6552522L ASC NULLS FIRST, demandStream#6823930 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#6823929, shardId#6552521, qty#6823949, worklistShardItemId#6552522L, demandStream#6823930, 30), ENSURE_REQUIREMENTS, [plan_id=29049115]\n +- SortAggregate(key=[demandChannel#6823929, shardId#6552521, knownfloatingpointnormalized(normalizenanandzero(qty#6823949)) AS qty#6823949, worklistShardItemId#6552522L, demandStream#6823930], functions=[partial_first(kpis#6823958, false)], output=[demandChannel#6823929, shardId#6552521, qty#6823949, worklistShardItemId#6552522L... [423021] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1105983 { id="cluster_1105983"; isCluster="true"; label="InMemoryTableScan"; 423061 [id="node_423061" labelType="html" label="MapPartitionsRDD [423061] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 423062 [id="node_423062" labelType="html" label="MapPartitionsRDD [423062] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 423063 [id="node_423063" labelType="html" label="MapPartitionsRDD [423063] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1105980 { id="cluster_1105980"; isCluster="true"; label="WholeStageCodegen (1)"; 423064 [id="node_423064" labelType="html" label="MapPartitionsRDD [423064] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1105979 { id="cluster_1105979"; isCluster="true"; label="Exchange"; 423065 [id="node_423065" labelType="html" label="MapPartitionsRDD [423065] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 423017->423018; 423018->423019; 423019->423020; 423020->423021; 423021->423061; 423061->423062; 423062->423063; 423063->423064; 423064->423065; }

423016,423017

423021

Event Timeline

Enable zooming