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

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 30
Input Size / Records: 7.7 MiB / 90
Shuffle Write Size / Records: 7.4 MiB / 410552
Associated Job Ids: 66411

digraph G { id="graph_241158"; subgraph graph_stage_241158 { id="graph_stage_241158"; isCluster="true"; label="Stage 241158"; subgraph cluster_1409217 { id="cluster_1409217"; isCluster="true"; label="Exchange"; 539600 [id="node_539600" labelType="html" label="ShuffledRowRDD [539600] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409214 { id="cluster_1409214"; isCluster="true"; label="WholeStageCodegen (7)"; 539601 [id="node_539601" labelType="html" label="MapPartitionsRDD [539601] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409213 { id="cluster_1409213"; isCluster="true"; label="SortAggregate"; 539602 [id="node_539602" labelType="html" label="MapPartitionsRDD [539602] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409212 { id="cluster_1409212"; isCluster="true"; label="InMemoryTableScan"; 539603 [id="node_539603" labelType="html" label="MapPartitionsRDD [539603] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 539604 [id="node_539604" labelType="html" label="SortAggregate(key=[demandChannel#8700789, shardId#8398780, qty#8700809, worklistShardItemId#8398781L, demandStream#8700790], functions=[first(kpis#8700818, false)], output=[shardId#8398780, worklistShardItemId#8398781L, qty#8700809, demandChannel#8700789, demandStream#8700790, kpis#8700931])\n+- *(7) Sort [demandChannel#8700789 ASC NULLS FIRST, shardId#8398780 ASC NULLS FIRST, qty#8700809 ASC NULLS FIRST, worklistShardItemId#8398781L ASC NULLS FIRST, demandStream#8700790 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#8700789, shardId#8398780, qty#8700809, worklistShardItemId#8398781L, demandStream#8700790, 30), ENSURE_REQUIREMENTS, [plan_id=36540727]\n +- SortAggregate(key=[demandChannel#8700789, shardId#8398780, knownfloatingpointnormalized(normalizenanandzero(qty#8700809)) AS qty#8700809, worklistShardItemId#8398781L, demandStream#8700790], functions=[partial_first(kpis#8700818, false)], output=[demandChannel#8700789, shardId#8398780, qty#8700809, worklistShardItemId#8398781L... [539604] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409324 { id="cluster_1409324"; isCluster="true"; label="InMemoryTableScan"; 539611 [id="node_539611" labelType="html" label="MapPartitionsRDD [539611] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 539612 [id="node_539612" labelType="html" label="MapPartitionsRDD [539612] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 539613 [id="node_539613" labelType="html" label="MapPartitionsRDD [539613] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409321 { id="cluster_1409321"; isCluster="true"; label="WholeStageCodegen (1)"; 539614 [id="node_539614" labelType="html" label="MapPartitionsRDD [539614] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409320 { id="cluster_1409320"; isCluster="true"; label="Exchange"; 539615 [id="node_539615" labelType="html" label="MapPartitionsRDD [539615] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 539600->539601; 539601->539602; 539602->539603; 539603->539604; 539604->539611; 539611->539612; 539612->539613; 539613->539614; 539614->539615; }

539599,539600

539604

Event Timeline

Enable zooming