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

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 37
Input Size / Records: 3.7 KiB / 6
Shuffle Write Size / Records: 552.0 B / 6
Associated Job Ids: 4951

digraph G { id="graph_94948"; subgraph graph_stage_94948 { id="graph_stage_94948"; isCluster="true"; label="Stage 94948"; subgraph cluster_112617 { id="cluster_112617"; isCluster="true"; label="Exchange"; 43260 [id="node_43260" labelType="html" label="ShuffledRowRDD [43260] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112612 { id="cluster_112612"; isCluster="true"; label="WholeStageCodegen (6)"; 43261 [id="node_43261" labelType="html" label="MapPartitionsRDD [43261] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112611 { id="cluster_112611"; isCluster="true"; label="SortAggregate"; 43262 [id="node_43262" labelType="html" label="MapPartitionsRDD [43262] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112610 { id="cluster_112610"; isCluster="true"; label="InMemoryTableScan"; 43263 [id="node_43263" labelType="html" label="MapPartitionsRDD [43263] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 43264 [id="node_43264" labelType="html" label="SortAggregate(key=[demandChannel#868540, shardId#815740, qty#868560, worklistShardItemId#815741L, demandStream#868541], functions=[first(kpis#868569, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#868560, demandChannel#868540, demandStream#868541, kpis#868702])\n+- *(6) Sort [demandChannel#868540 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#868560 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#868541 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#868540, shardId#815740, qty#868560, worklistShardItemId#815741L, demandStream#868541, 37), ENSURE_REQUIREMENTS, [plan_id=1384066]\n +- SortAggregate(key=[demandChannel#868540, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#868560)) AS qty#868560, worklistShardItemId#815741L, demandStream#868541], functions=[partial_first(kpis#868569, false)], output=[demandChannel#868540, shardId#815740, qty#868560, worklistShardItemId#815741L, demandStream#868541, first#86877... [43264] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112713 { id="cluster_112713"; isCluster="true"; label="InMemoryTableScan"; 43277 [id="node_43277" labelType="html" label="MapPartitionsRDD [43277] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 43278 [id="node_43278" labelType="html" label="MapPartitionsRDD [43278] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 43279 [id="node_43279" labelType="html" label="MapPartitionsRDD [43279] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112710 { id="cluster_112710"; isCluster="true"; label="WholeStageCodegen (1)"; 43280 [id="node_43280" labelType="html" label="MapPartitionsRDD [43280] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112709 { id="cluster_112709"; isCluster="true"; label="Exchange"; 43281 [id="node_43281" labelType="html" label="MapPartitionsRDD [43281] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 43260->43261; 43261->43262; 43262->43263; 43263->43264; 43264->43277; 43277->43278; 43278->43279; 43279->43280; 43280->43281; }

43259,43260

43264

43260

43261

43262

43263

43264

43277

43278

43279

43280

43281

Event Timeline

Enable zooming