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

Resource Profile Id: 0
Total Time Across All Tasks: 1 s
Locality Level Summary: Process local: 30
Input Size / Records: 8.9 MiB / 90
Shuffle Write Size / Records: 8.6 MiB / 479816
Associated Job Ids: 66439

digraph G { id="graph_241314"; subgraph graph_stage_241314 { id="graph_stage_241314"; isCluster="true"; label="Stage 241314"; subgraph cluster_1410176 { id="cluster_1410176"; isCluster="true"; label="Exchange"; 539961 [id="node_539961" labelType="html" label="ShuffledRowRDD [539961] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410173 { id="cluster_1410173"; isCluster="true"; label="WholeStageCodegen (7)"; 539962 [id="node_539962" labelType="html" label="MapPartitionsRDD [539962] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410172 { id="cluster_1410172"; isCluster="true"; label="SortAggregate"; 539963 [id="node_539963" labelType="html" label="MapPartitionsRDD [539963] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410171 { id="cluster_1410171"; isCluster="true"; label="InMemoryTableScan"; 539964 [id="node_539964" labelType="html" label="MapPartitionsRDD [539964] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 539965 [id="node_539965" labelType="html" label="SortAggregate(key=[demandChannel#8706280, shardId#8398780, qty#8706300, worklistShardItemId#8398781L, demandStream#8706281], functions=[first(kpis#8706309, false)], output=[shardId#8398780, worklistShardItemId#8398781L, qty#8706300, demandChannel#8706280, demandStream#8706281, kpis#8706422])\n+- *(7) Sort [demandChannel#8706280 ASC NULLS FIRST, shardId#8398780 ASC NULLS FIRST, qty#8706300 ASC NULLS FIRST, worklistShardItemId#8398781L ASC NULLS FIRST, demandStream#8706281 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#8706280, shardId#8398780, qty#8706300, worklistShardItemId#8398781L, demandStream#8706281, 30), ENSURE_REQUIREMENTS, [plan_id=36542996]\n +- SortAggregate(key=[demandChannel#8706280, shardId#8398780, knownfloatingpointnormalized(normalizenanandzero(qty#8706300)) AS qty#8706300, worklistShardItemId#8398781L, demandStream#8706281], functions=[partial_first(kpis#8706309, false)], output=[demandChannel#8706280, shardId#8398780, qty#8706300, worklistShardItemId#8398781L... [539965] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410283 { id="cluster_1410283"; isCluster="true"; label="InMemoryTableScan"; 539972 [id="node_539972" labelType="html" label="MapPartitionsRDD [539972] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 539973 [id="node_539973" labelType="html" label="MapPartitionsRDD [539973] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 539974 [id="node_539974" labelType="html" label="MapPartitionsRDD [539974] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410280 { id="cluster_1410280"; isCluster="true"; label="WholeStageCodegen (1)"; 539975 [id="node_539975" labelType="html" label="MapPartitionsRDD [539975] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410279 { id="cluster_1410279"; isCluster="true"; label="Exchange"; 539976 [id="node_539976" labelType="html" label="MapPartitionsRDD [539976] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 539961->539962; 539962->539963; 539963->539964; 539964->539965; 539965->539972; 539972->539973; 539973->539974; 539974->539975; 539975->539976; }

539960,539961

539965

Event Timeline

Enable zooming