4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 117593 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
5 s
Locality Level Summary:
Node local: 36; Process local: 1
Shuffle Read Size / Records:
624.2 KiB / 402
Shuffle Write Size / Records:
507.5 KiB / 125
Associated Job Ids:
6471
DAG Visualization
digraph G { id="graph_117593"; subgraph graph_stage_117593 { id="graph_stage_117593"; isCluster="true"; label="Stage 117593"; subgraph cluster_148040 { id="cluster_148040"; isCluster="true"; label="Exchange"; 57047 [id="node_57047" labelType="html" label="ShuffledRowRDD [57047] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148037 { id="cluster_148037"; isCluster="true"; label="WholeStageCodegen (4)"; 57048 [id="node_57048" labelType="html" label="MapPartitionsRDD [57048] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148060 { id="cluster_148060"; isCluster="true"; label="Exchange"; 57058 [id="node_57058" labelType="html" label="ShuffledRowRDD [57058] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148057 { id="cluster_148057"; isCluster="true"; label="WholeStageCodegen (8)"; 57059 [id="node_57059" labelType="html" label="MapPartitionsRDD [57059] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148033 { id="cluster_148033"; isCluster="true"; label="WholeStageCodegen (9)"; 57060 [id="node_57060" labelType="html" label="ZippedPartitionsRDD2 [57060] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 57061 [id="node_57061" labelType="html" label="MapPartitionsRDD [57061] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148032 { id="cluster_148032"; isCluster="true"; label="ObjectHashAggregate"; 57062 [id="node_57062" labelType="html" label="MapPartitionsRDD [57062] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148031 { id="cluster_148031"; isCluster="true"; label="Exchange"; 57063 [id="node_57063" labelType="html" label="MapPartitionsRDD [57063] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } } 57047->57048; 57058->57059; 57048->57060; 57059->57060; 57060->57061; 57061->57062; 57062->57063; }
57046,57047
57057,57058
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