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

Resource Profile Id: 0
Total Time Across All Tasks: 1 s
Locality Level Summary: Process local: 37
Input Size / Records: 1795.0 B / 2
Shuffle Write Size / Records: 184.0 B / 2
Associated Job Ids: 6180

digraph G { id="graph_113853"; subgraph graph_stage_113853 { id="graph_stage_113853"; isCluster="true"; label="Stage 113853"; subgraph cluster_141334 { id="cluster_141334"; isCluster="true"; label="Exchange"; 54420 [id="node_54420" labelType="html" label="ShuffledRowRDD [54420] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141328 { id="cluster_141328"; isCluster="true"; label="WholeStageCodegen (6)"; 54421 [id="node_54421" labelType="html" label="MapPartitionsRDD [54421] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141327 { id="cluster_141327"; isCluster="true"; label="SortAggregate"; 54422 [id="node_54422" labelType="html" label="MapPartitionsRDD [54422] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141326 { id="cluster_141326"; isCluster="true"; label="InMemoryTableScan"; 54423 [id="node_54423" labelType="html" label="MapPartitionsRDD [54423] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 54424 [id="node_54424" labelType="html" label="SortAggregate(key=[demandChannel#1092394, shardId#1011815, qty#1092414, worklistShardItemId#1011816L, demandStream#1092395], functions=[first(kpis#1092423, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1092414, demandChannel#1092394, demandStream#1092395, kpis#1092556])\n+- *(6) Sort [demandChannel#1092394 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1092414 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1092395 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1092394, shardId#1011815, qty#1092414, worklistShardItemId#1011816L, demandStream#1092395, 37), ENSURE_REQUIREMENTS, [plan_id=1696762]\n +- SortAggregate(key=[demandChannel#1092394, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1092414)) AS qty#1092414, worklistShardItemId#1011816L, demandStream#1092395], functions=[partial_first(kpis#1092423, false)], output=[demandChannel#1092394, shardId#1011815, qty#1092414, worklistShardItemId#1011816L,... [54424] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141429 { id="cluster_141429"; isCluster="true"; label="InMemoryTableScan"; 54437 [id="node_54437" labelType="html" label="MapPartitionsRDD [54437] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 54438 [id="node_54438" labelType="html" label="MapPartitionsRDD [54438] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 54439 [id="node_54439" labelType="html" label="MapPartitionsRDD [54439] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141426 { id="cluster_141426"; isCluster="true"; label="WholeStageCodegen (1)"; 54440 [id="node_54440" labelType="html" label="MapPartitionsRDD [54440] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141425 { id="cluster_141425"; isCluster="true"; label="Exchange"; 54441 [id="node_54441" labelType="html" label="MapPartitionsRDD [54441] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 54420->54421; 54421->54422; 54422->54423; 54423->54424; 54424->54437; 54437->54438; 54438->54439; 54439->54440; 54440->54441; }

54419,54420

54424

54420

54421

54422

54423

54424

54437

54438

54439

54440

54441

Event Timeline

Enable zooming