4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 190502 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
18 s
Locality Level Summary:
Node local: 30
Shuffle Read Size / Records:
40.0 MiB / 479444
Shuffle Write Size / Records:
31.1 MiB / 235864
Associated Job Ids:
52643
DAG Visualization
digraph G { id="graph_190502"; subgraph graph_stage_190502 { id="graph_stage_190502"; isCluster="true"; label="Stage 190502"; subgraph cluster_1108754 { id="cluster_1108754"; isCluster="true"; label="Exchange"; 424210 [id="node_424210" labelType="html" label="ShuffledRowRDD [424210] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108751 { id="cluster_1108751"; isCluster="true"; label="WholeStageCodegen (9)"; 424211 [id="node_424211" labelType="html" label="MapPartitionsRDD [424211] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108803 { id="cluster_1108803"; isCluster="true"; label="Exchange"; 424237 [id="node_424237" labelType="html" label="ShuffledRowRDD [424237] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108800 { id="cluster_1108800"; isCluster="true"; label="WholeStageCodegen (17)"; 424238 [id="node_424238" labelType="html" label="MapPartitionsRDD [424238] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108747 { id="cluster_1108747"; isCluster="true"; label="WholeStageCodegen (18)"; 424239 [id="node_424239" labelType="html" label="ZippedPartitionsRDD2 [424239] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 424240 [id="node_424240" labelType="html" label="MapPartitionsRDD [424240] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108746 { id="cluster_1108746"; isCluster="true"; label="ObjectHashAggregate"; 424241 [id="node_424241" labelType="html" label="MapPartitionsRDD [424241] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108745 { id="cluster_1108745"; isCluster="true"; label="Exchange"; 424242 [id="node_424242" labelType="html" label="MapPartitionsRDD [424242] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 424210->424211; 424237->424238; 424211->424239; 424238->424239; 424239->424240; 424240->424241; 424241->424242; }
424209,424210
424236,424237
Event Timeline
Enable zooming
Tasks: 30. 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