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

Resource Profile Id: 0
Total Time Across All Tasks: 0.8 s
Locality Level Summary: Process local: 30
Input Size / Records: 2.8 MiB / 30
Shuffle Write Size / Records: 2.9 MiB / 148160
Associated Job Ids: 66419

digraph G { id="graph_241217"; subgraph graph_stage_241217 { id="graph_stage_241217"; isCluster="true"; label="Stage 241217"; subgraph cluster_1409502 { id="cluster_1409502"; isCluster="true"; label="Exchange"; 539696 [id="node_539696" labelType="html" label="ShuffledRowRDD [539696] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409499 { id="cluster_1409499"; isCluster="true"; label="WholeStageCodegen (7)"; 539697 [id="node_539697" labelType="html" label="MapPartitionsRDD [539697] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409498 { id="cluster_1409498"; isCluster="true"; label="SortAggregate"; 539698 [id="node_539698" labelType="html" label="MapPartitionsRDD [539698] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409497 { id="cluster_1409497"; isCluster="true"; label="InMemoryTableScan"; 539699 [id="node_539699" labelType="html" label="MapPartitionsRDD [539699] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 539700 [id="node_539700" labelType="html" label="SortAggregate(key=[demandChannel#8702179, shardId#8398756, qty#8702199, worklistShardItemId#8398757L, demandStream#8702180], functions=[first(kpis#8702208, false)], output=[shardId#8398756, worklistShardItemId#8398757L, qty#8702199, demandChannel#8702179, demandStream#8702180, kpis#8702321])\n+- *(7) Sort [demandChannel#8702179 ASC NULLS FIRST, shardId#8398756 ASC NULLS FIRST, qty#8702199 ASC NULLS FIRST, worklistShardItemId#8398757L ASC NULLS FIRST, demandStream#8702180 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#8702179, shardId#8398756, qty#8702199, worklistShardItemId#8398757L, demandStream#8702180, 30), ENSURE_REQUIREMENTS, [plan_id=36541344]\n +- SortAggregate(key=[demandChannel#8702179, shardId#8398756, knownfloatingpointnormalized(normalizenanandzero(qty#8702199)) AS qty#8702199, worklistShardItemId#8398757L, demandStream#8702180], functions=[partial_first(kpis#8702208, false)], output=[demandChannel#8702179, shardId#8398756, qty#8702199, worklistShardItemId#8398757L... [539700] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409632 { id="cluster_1409632"; isCluster="true"; label="InMemoryTableScan"; 539707 [id="node_539707" labelType="html" label="MapPartitionsRDD [539707] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 539708 [id="node_539708" labelType="html" label="MapPartitionsRDD [539708] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 539709 [id="node_539709" labelType="html" label="MapPartitionsRDD [539709] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409629 { id="cluster_1409629"; isCluster="true"; label="WholeStageCodegen (1)"; 539710 [id="node_539710" labelType="html" label="MapPartitionsRDD [539710] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409628 { id="cluster_1409628"; isCluster="true"; label="Exchange"; 539711 [id="node_539711" labelType="html" label="MapPartitionsRDD [539711] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 539696->539697; 539697->539698; 539698->539699; 539699->539700; 539700->539707; 539707->539708; 539708->539709; 539709->539710; 539710->539711; }

539695,539696

539700

Event Timeline

Enable zooming