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

Resource Profile Id: 0
Total Time Across All Tasks: 3 s
Locality Level Summary: Process local: 37
Input Size / Records: 30.7 KiB / 37
Shuffle Write Size / Records: 3.3 KiB / 37
Associated Job Ids: 5699

digraph G { id="graph_102658"; subgraph graph_stage_102658 { id="graph_stage_102658"; isCluster="true"; label="Stage 102658"; subgraph cluster_128790 { id="cluster_128790"; isCluster="true"; label="Exchange"; 49325 [id="node_49325" labelType="html" label="ShuffledRowRDD [49325] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128785 { id="cluster_128785"; isCluster="true"; label="WholeStageCodegen (6)"; 49326 [id="node_49326" labelType="html" label="MapPartitionsRDD [49326] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128784 { id="cluster_128784"; isCluster="true"; label="SortAggregate"; 49327 [id="node_49327" labelType="html" label="MapPartitionsRDD [49327] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128783 { id="cluster_128783"; isCluster="true"; label="InMemoryTableScan"; 49328 [id="node_49328" labelType="html" label="MapPartitionsRDD [49328] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 49329 [id="node_49329" labelType="html" label="SortAggregate(key=[demandChannel#987078, shardId#943631, qty#987098, worklistShardItemId#943632L, demandStream#987079], functions=[first(kpis#987107, false)], output=[shardId#943631, worklistShardItemId#943632L, qty#987098, demandChannel#987078, demandStream#987079, kpis#987240])\n+- *(6) Sort [demandChannel#987078 ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST, qty#987098 ASC NULLS FIRST, worklistShardItemId#943632L ASC NULLS FIRST, demandStream#987079 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#987078, shardId#943631, qty#987098, worklistShardItemId#943632L, demandStream#987079, 37), ENSURE_REQUIREMENTS, [plan_id=1626640]\n +- SortAggregate(key=[demandChannel#987078, shardId#943631, knownfloatingpointnormalized(normalizenanandzero(qty#987098)) AS qty#987098, worklistShardItemId#943632L, demandStream#987079], functions=[partial_first(kpis#987107, false)], output=[demandChannel#987078, shardId#943631, qty#987098, worklistShardItemId#943632L, demandStream#987079, first#98731... [49329] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128886 { id="cluster_128886"; isCluster="true"; label="InMemoryTableScan"; 49342 [id="node_49342" labelType="html" label="MapPartitionsRDD [49342] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 49343 [id="node_49343" labelType="html" label="MapPartitionsRDD [49343] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 49344 [id="node_49344" labelType="html" label="MapPartitionsRDD [49344] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128883 { id="cluster_128883"; isCluster="true"; label="WholeStageCodegen (1)"; 49345 [id="node_49345" labelType="html" label="MapPartitionsRDD [49345] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128882 { id="cluster_128882"; isCluster="true"; label="Exchange"; 49346 [id="node_49346" labelType="html" label="MapPartitionsRDD [49346] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 49325->49326; 49326->49327; 49327->49328; 49328->49329; 49329->49342; 49342->49343; 49343->49344; 49344->49345; 49345->49346; }

49324,49325

49329

49325

49326

49327

49328

49329

49342

49343

49344

49345

49346

Event Timeline

Enable zooming