4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 113943 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
9 s
Locality Level Summary:
Process local: 74
Input Size / Records:
63.5 KiB / 475
Shuffle Write Size / Records:
253.3 KiB / 475
Associated Job Ids:
6181
DAG Visualization
digraph G { id="graph_113943"; subgraph graph_stage_113943 { id="graph_stage_113943"; isCluster="true"; label="Stage 113943"; 54435 [id="node_54435" labelType="html" label="SQLExecutionRDD [54435] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_140823 { id="cluster_140823"; isCluster="true"; label="repartition"; 54187 [id="node_54187" labelType="html" label="ShuffledRDD [54187] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54188 [id="node_54188" labelType="html" label="CoalescedRDD [54188] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54189 [id="node_54189" labelType="html" label="MapPartitionsRDD [54189] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141334 { id="cluster_141334"; isCluster="true"; label="Exchange"; 54420 [id="node_54420" labelType="html" label="ShuffledRowRDD [54420] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141328 { id="cluster_141328"; isCluster="true"; label="WholeStageCodegen (6)"; 54421 [id="node_54421" labelType="html" label="MapPartitionsRDD [54421] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141327 { id="cluster_141327"; isCluster="true"; label="SortAggregate"; 54422 [id="node_54422" labelType="html" label="MapPartitionsRDD [54422] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141326 { id="cluster_141326"; isCluster="true"; label="InMemoryTableScan"; 54423 [id="node_54423" labelType="html" label="MapPartitionsRDD [54423] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54424 [id="node_54424" labelType="html" label="SortAggregate(key=[demandChannel#1092394, shardId#1011815, qty#1092414, worklistShardItemId#1011816L, demandStream#1092395], functions=[first(kpis#1092423, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1092414, demandChannel#1092394, demandStream#1092395, kpis#1092556])\n+- *(6) Sort [demandChannel#1092394 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1092414 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1092395 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1092394, shardId#1011815, qty#1092414, worklistShardItemId#1011816L, demandStream#1092395, 37), ENSURE_REQUIREMENTS, [plan_id=1696762]\n +- SortAggregate(key=[demandChannel#1092394, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1092414)) AS qty#1092414, worklistShardItemId#1011816L, demandStream#1092395], functions=[partial_first(kpis#1092423, false)], output=[demandChannel#1092394, shardId#1011815, qty#1092414, worklistShardItemId#1011816L,... [54424] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141420 { id="cluster_141420"; isCluster="true"; label="InMemoryTableScan"; 54431 [id="node_54431" labelType="html" label="MapPartitionsRDD [54431] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54432 [id="node_54432" labelType="html" label="MapPartitionsRDD [54432] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54433 [id="node_54433" labelType="html" label="MapPartitionsRDD [54433] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141419 { id="cluster_141419"; isCluster="true"; label="DeserializeToObject"; 54434 [id="node_54434" labelType="html" label="MapPartitionsRDD [54434] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141421 { id="cluster_141421"; isCluster="true"; label="mapPartitions"; 54436 [id="node_54436" labelType="html" label="MapPartitionsRDD [54436] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141441 { id="cluster_141441"; isCluster="true"; label="union"; 54445 [id="node_54445" labelType="html" label="UnionRDD [54445] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141442 { id="cluster_141442"; isCluster="true"; label="filter"; 54446 [id="node_54446" labelType="html" label="MapPartitionsRDD [54446] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141443 { id="cluster_141443"; isCluster="true"; label="distinct"; 54447 [id="node_54447" labelType="html" label="MapPartitionsRDD [54447] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 54187->54188; 54188->54189; 54420->54421; 54421->54422; 54422->54423; 54423->54424; 54424->54431; 54431->54432; 54432->54433; 54433->54434; 54434->54435; 54435->54436; 54189->54445; 54436->54445; 54445->54446; 54446->54447; }
54186,54187
54419,54420
54189
54424
54435
54187
54188
54189
54420
54421
54422
54423
54424
54431
54432
54433
54434
54436
54445
54446
54447
Event Timeline
Enable zooming
Tasks: 74. 1 Pages. Jump to
. Show
items in a page.
Go
Scheduler Delay
Task Deserialization Time
Shuffle Read Time
Executor Computing Time
Shuffle Write Time
Result Serialization Time
Getting Result Time