4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 118110 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
6 s
Locality Level Summary:
Node local: 20; Process local: 17
Shuffle Read Size / Records:
111.0 KiB / 52
Shuffle Write Size / Records:
109.6 KiB / 26
Associated Job Ids:
6492
DAG Visualization
digraph G { id="graph_118110"; subgraph graph_stage_118110 { id="graph_stage_118110"; isCluster="true"; label="Stage 118110"; subgraph cluster_148649 { id="cluster_148649"; isCluster="true"; label="Exchange"; 57332 [id="node_57332" labelType="html" label="ShuffledRowRDD [57332] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148646 { id="cluster_148646"; isCluster="true"; label="WholeStageCodegen (10)"; 57333 [id="node_57333" labelType="html" label="MapPartitionsRDD [57333] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148711 { id="cluster_148711"; isCluster="true"; label="Exchange"; 57348 [id="node_57348" labelType="html" label="ShuffledRowRDD [57348] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148708 { id="cluster_148708"; isCluster="true"; label="WholeStageCodegen (13)"; 57349 [id="node_57349" labelType="html" label="MapPartitionsRDD [57349] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148642 { id="cluster_148642"; isCluster="true"; label="WholeStageCodegen (14)"; 57350 [id="node_57350" labelType="html" label="ZippedPartitionsRDD2 [57350] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57351 [id="node_57351" labelType="html" label="MapPartitionsRDD [57351] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148641 { id="cluster_148641"; isCluster="true"; label="ObjectHashAggregate"; 57352 [id="node_57352" labelType="html" label="MapPartitionsRDD [57352] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148640 { id="cluster_148640"; isCluster="true"; label="Exchange"; 57353 [id="node_57353" labelType="html" label="MapPartitionsRDD [57353] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 57332->57333; 57348->57349; 57333->57350; 57349->57350; 57350->57351; 57351->57352; 57352->57353; }
57331,57332
57347,57348
57348
57349
57350
57351
57352
57353
Event Timeline
Enable zooming
Tasks: 37. 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