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

Resource Profile Id: 0
Total Time Across All Tasks: 1 s
Locality Level Summary: Process local: 37
Input Size / Records: 14.5 KiB / 25
Shuffle Write Size / Records: 2.2 KiB / 25
Associated Job Ids: 4867

digraph G { id="graph_91056"; subgraph graph_stage_91056 { id="graph_stage_91056"; isCluster="true"; label="Stage 91056"; subgraph cluster_110133 { id="cluster_110133"; isCluster="true"; label="Exchange"; 42204 [id="node_42204" labelType="html" label="ShuffledRowRDD [42204] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110128 { id="cluster_110128"; isCluster="true"; label="WholeStageCodegen (6)"; 42205 [id="node_42205" labelType="html" label="MapPartitionsRDD [42205] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110127 { id="cluster_110127"; isCluster="true"; label="SortAggregate"; 42206 [id="node_42206" labelType="html" label="MapPartitionsRDD [42206] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110126 { id="cluster_110126"; isCluster="true"; label="InMemoryTableScan"; 42207 [id="node_42207" labelType="html" label="MapPartitionsRDD [42207] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 42208 [id="node_42208" labelType="html" label="SortAggregate(key=[demandChannel#846308, shardId#815740, qty#846328, worklistShardItemId#815741L, demandStream#846309], functions=[first(kpis#846337, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#846328, demandChannel#846308, demandStream#846309, kpis#846470])\n+- *(6) Sort [demandChannel#846308 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#846328 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#846309 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#846308, shardId#815740, qty#846328, worklistShardItemId#815741L, demandStream#846309, 37), ENSURE_REQUIREMENTS, [plan_id=1377777]\n +- SortAggregate(key=[demandChannel#846308, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#846328)) AS qty#846328, worklistShardItemId#815741L, demandStream#846309], functions=[partial_first(kpis#846337, false)], output=[demandChannel#846308, shardId#815740, qty#846328, worklistShardItemId#815741L, demandStream#846309, first#84654... [42208] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110229 { id="cluster_110229"; isCluster="true"; label="InMemoryTableScan"; 42221 [id="node_42221" labelType="html" label="MapPartitionsRDD [42221] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 42222 [id="node_42222" labelType="html" label="MapPartitionsRDD [42222] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 42223 [id="node_42223" labelType="html" label="MapPartitionsRDD [42223] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110226 { id="cluster_110226"; isCluster="true"; label="WholeStageCodegen (1)"; 42224 [id="node_42224" labelType="html" label="MapPartitionsRDD [42224] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110225 { id="cluster_110225"; isCluster="true"; label="Exchange"; 42225 [id="node_42225" labelType="html" label="MapPartitionsRDD [42225] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 42204->42205; 42205->42206; 42206->42207; 42207->42208; 42208->42221; 42221->42222; 42222->42223; 42223->42224; 42224->42225; }

42203,42204

42208

42204

42205

42206

42207

42208

42221

42222

42223

42224

42225

Event Timeline

Enable zooming