4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 90848 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
6 s
Locality Level Summary:
Node local: 21; Process local: 16
Shuffle Read Size / Records:
179.2 KiB / 116
Shuffle Write Size / Records:
137.0 KiB / 34
Associated Job Ids:
4864
DAG Visualization
digraph G { id="graph_90848"; subgraph graph_stage_90848 { id="graph_stage_90848"; isCluster="true"; label="Stage 90848"; subgraph cluster_110002 { id="cluster_110002"; isCluster="true"; label="Exchange"; 42124 [id="node_42124" labelType="html" label="ShuffledRowRDD [42124] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109999 { id="cluster_109999"; isCluster="true"; label="WholeStageCodegen (4)"; 42125 [id="node_42125" labelType="html" label="MapPartitionsRDD [42125] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110022 { id="cluster_110022"; isCluster="true"; label="Exchange"; 42135 [id="node_42135" labelType="html" label="ShuffledRowRDD [42135] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110019 { id="cluster_110019"; isCluster="true"; label="WholeStageCodegen (8)"; 42136 [id="node_42136" labelType="html" label="MapPartitionsRDD [42136] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109995 { id="cluster_109995"; isCluster="true"; label="WholeStageCodegen (9)"; 42137 [id="node_42137" labelType="html" label="ZippedPartitionsRDD2 [42137] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 42138 [id="node_42138" labelType="html" label="MapPartitionsRDD [42138] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109994 { id="cluster_109994"; isCluster="true"; label="ObjectHashAggregate"; 42139 [id="node_42139" labelType="html" label="MapPartitionsRDD [42139] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109993 { id="cluster_109993"; isCluster="true"; label="Exchange"; 42140 [id="node_42140" labelType="html" label="MapPartitionsRDD [42140] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } } 42124->42125; 42135->42136; 42125->42137; 42136->42137; 42137->42138; 42138->42139; 42139->42140; }
42123,42124
42134,42135
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