4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 91445 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
5 s
Locality Level Summary:
Node local: 19; Process local: 18
Shuffle Read Size / Records:
138.1 KiB / 96
Shuffle Write Size / Records:
121.0 KiB / 30
Associated Job Ids:
4885
DAG Visualization
digraph G { id="graph_91445"; subgraph graph_stage_91445 { id="graph_stage_91445"; isCluster="true"; label="Stage 91445"; subgraph cluster_110623 { id="cluster_110623"; isCluster="true"; label="Exchange"; 42388 [id="node_42388" labelType="html" label="ShuffledRowRDD [42388] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110620 { id="cluster_110620"; isCluster="true"; label="WholeStageCodegen (4)"; 42389 [id="node_42389" labelType="html" label="MapPartitionsRDD [42389] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110643 { id="cluster_110643"; isCluster="true"; label="Exchange"; 42399 [id="node_42399" labelType="html" label="ShuffledRowRDD [42399] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110640 { id="cluster_110640"; isCluster="true"; label="WholeStageCodegen (8)"; 42400 [id="node_42400" labelType="html" label="MapPartitionsRDD [42400] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110616 { id="cluster_110616"; isCluster="true"; label="WholeStageCodegen (9)"; 42401 [id="node_42401" labelType="html" label="ZippedPartitionsRDD2 [42401] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 42402 [id="node_42402" labelType="html" label="MapPartitionsRDD [42402] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110615 { id="cluster_110615"; isCluster="true"; label="ObjectHashAggregate"; 42403 [id="node_42403" labelType="html" label="MapPartitionsRDD [42403] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110614 { id="cluster_110614"; isCluster="true"; label="Exchange"; 42404 [id="node_42404" labelType="html" label="MapPartitionsRDD [42404] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } } 42388->42389; 42399->42400; 42389->42401; 42400->42401; 42401->42402; 42402->42403; 42403->42404; }
42387,42388
42398,42399
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