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

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

digraph G { id="graph_117098"; subgraph graph_stage_117098 { id="graph_stage_117098"; isCluster="true"; label="Stage 117098"; subgraph cluster_146930 { id="cluster_146930"; isCluster="true"; label="Exchange"; 56599 [id="node_56599" labelType="html" label="ShuffledRowRDD [56599] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146924 { id="cluster_146924"; isCluster="true"; label="WholeStageCodegen (6)"; 56600 [id="node_56600" labelType="html" label="MapPartitionsRDD [56600] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146923 { id="cluster_146923"; isCluster="true"; label="SortAggregate"; 56601 [id="node_56601" labelType="html" label="MapPartitionsRDD [56601] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146922 { id="cluster_146922"; isCluster="true"; label="InMemoryTableScan"; 56602 [id="node_56602" labelType="html" label="MapPartitionsRDD [56602] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 56603 [id="node_56603" labelType="html" label="SortAggregate(key=[demandChannel#1136773, shardId#1100457, qty#1136793, worklistShardItemId#1100458L, demandStream#1136774], functions=[first(kpis#1136802, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1136793, demandChannel#1136773, demandStream#1136774, kpis#1136935])\n+- *(6) Sort [demandChannel#1136773 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1136793 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1136774 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1136773, shardId#1100457, qty#1136793, worklistShardItemId#1100458L, demandStream#1136774, 37), ENSURE_REQUIREMENTS, [plan_id=1757887]\n +- SortAggregate(key=[demandChannel#1136773, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1136793)) AS qty#1136793, worklistShardItemId#1100458L, demandStream#1136774], functions=[partial_first(kpis#1136802, false)], output=[demandChannel#1136773, shardId#1100457, qty#1136793, worklistShardItemId#1100458L,... [56603] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147025 { id="cluster_147025"; isCluster="true"; label="InMemoryTableScan"; 56616 [id="node_56616" labelType="html" label="MapPartitionsRDD [56616] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 56617 [id="node_56617" labelType="html" label="MapPartitionsRDD [56617] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 56618 [id="node_56618" labelType="html" label="MapPartitionsRDD [56618] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147022 { id="cluster_147022"; isCluster="true"; label="WholeStageCodegen (1)"; 56619 [id="node_56619" labelType="html" label="MapPartitionsRDD [56619] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147021 { id="cluster_147021"; isCluster="true"; label="Exchange"; 56620 [id="node_56620" labelType="html" label="MapPartitionsRDD [56620] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 56599->56600; 56600->56601; 56601->56602; 56602->56603; 56603->56616; 56616->56617; 56617->56618; 56618->56619; 56619->56620; }

56598,56599

56603

56599

56600

56601

56602

56603

56616

56617

56618

56619

56620

Event Timeline

Enable zooming