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

Resource Profile Id: 0
Total Time Across All Tasks: 4 s
Locality Level Summary: Process local: 37
Input Size / Records: 14.9 KiB / 25
Shuffle Write Size / Records: 2.2 KiB / 25
Associated Job Ids: 5783

digraph G { id="graph_105254"; subgraph graph_stage_105254 { id="graph_stage_105254"; isCluster="true"; label="Stage 105254"; subgraph cluster_131274 { id="cluster_131274"; isCluster="true"; label="Exchange"; 50381 [id="node_50381" labelType="html" label="ShuffledRowRDD [50381] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131269 { id="cluster_131269"; isCluster="true"; label="WholeStageCodegen (6)"; 50382 [id="node_50382" labelType="html" label="MapPartitionsRDD [50382] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131268 { id="cluster_131268"; isCluster="true"; label="SortAggregate"; 50383 [id="node_50383" labelType="html" label="MapPartitionsRDD [50383] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131267 { id="cluster_131267"; isCluster="true"; label="InMemoryTableScan"; 50384 [id="node_50384" labelType="html" label="MapPartitionsRDD [50384] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 50385 [id="node_50385" labelType="html" label="SortAggregate(key=[demandChannel#1009310, shardId#943631, qty#1009330, worklistShardItemId#943632L, demandStream#1009311], functions=[first(kpis#1009339, false)], output=[shardId#943631, worklistShardItemId#943632L, qty#1009330, demandChannel#1009310, demandStream#1009311, kpis#1009472])\n+- *(6) Sort [demandChannel#1009310 ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST, qty#1009330 ASC NULLS FIRST, worklistShardItemId#943632L ASC NULLS FIRST, demandStream#1009311 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1009310, shardId#943631, qty#1009330, worklistShardItemId#943632L, demandStream#1009311, 37), ENSURE_REQUIREMENTS, [plan_id=1632985]\n +- SortAggregate(key=[demandChannel#1009310, shardId#943631, knownfloatingpointnormalized(normalizenanandzero(qty#1009330)) AS qty#1009330, worklistShardItemId#943632L, demandStream#1009311], functions=[partial_first(kpis#1009339, false)], output=[demandChannel#1009310, shardId#943631, qty#1009330, worklistShardItemId#943632L, demandStrea... [50385] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131370 { id="cluster_131370"; isCluster="true"; label="InMemoryTableScan"; 50398 [id="node_50398" labelType="html" label="MapPartitionsRDD [50398] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 50399 [id="node_50399" labelType="html" label="MapPartitionsRDD [50399] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 50400 [id="node_50400" labelType="html" label="MapPartitionsRDD [50400] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131367 { id="cluster_131367"; isCluster="true"; label="WholeStageCodegen (1)"; 50401 [id="node_50401" labelType="html" label="MapPartitionsRDD [50401] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131366 { id="cluster_131366"; isCluster="true"; label="Exchange"; 50402 [id="node_50402" labelType="html" label="MapPartitionsRDD [50402] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 50381->50382; 50382->50383; 50383->50384; 50384->50385; 50385->50398; 50398->50399; 50399->50400; 50400->50401; 50401->50402; }

50380,50381

50385

50381

50382

50383

50384

50385

50398

50399

50400

50401

50402

Event Timeline

Enable zooming