4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 190504 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2.4 min
Locality Level Summary:
Any: 20; Node local: 10
Shuffle Read Size / Records:
19.3 MiB / 239722
Associated Job Ids:
52643
DAG Visualization
digraph G { id="graph_190504"; subgraph graph_stage_190504 { id="graph_stage_190504"; isCluster="true"; label="Stage 190504"; 424269 [id="node_424269" labelType="html" label="SQLExecutionRDD [424269] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1108742 { id="cluster_1108742"; isCluster="true"; label="Exchange"; 424247 [id="node_424247" labelType="html" label="ShuffledRowRDD [424247] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108739 { id="cluster_1108739"; isCluster="true"; label="WholeStageCodegen (19)"; 424248 [id="node_424248" labelType="html" label="MapPartitionsRDD [424248] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108864 { id="cluster_1108864"; isCluster="true"; label="Exchange"; 424261 [id="node_424261" labelType="html" label="ShuffledRowRDD [424261] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108861 { id="cluster_1108861"; isCluster="true"; label="WholeStageCodegen (22)"; 424262 [id="node_424262" labelType="html" label="MapPartitionsRDD [424262] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108734 { id="cluster_1108734"; isCluster="true"; label="WholeStageCodegen (23)"; 424263 [id="node_424263" labelType="html" label="ZippedPartitionsRDD2 [424263] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 424264 [id="node_424264" labelType="html" label="MapPartitionsRDD [424264] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108733 { id="cluster_1108733"; isCluster="true"; label="DeserializeToObject"; 424265 [id="node_424265" labelType="html" label="MapPartitionsRDD [424265] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108732 { id="cluster_1108732"; isCluster="true"; label="MapPartitions"; 424266 [id="node_424266" labelType="html" label="MapPartitionsRDD [424266] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108710 { id="cluster_1108710"; isCluster="true"; label="WholeStageCodegen (26)"; 424267 [id="node_424267" labelType="html" label="MapPartitionsRDD [424267] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108709 { id="cluster_1108709"; isCluster="true"; label="DeserializeToObject"; 424268 [id="node_424268" labelType="html" label="MapPartitionsRDD [424268] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108877 { id="cluster_1108877"; isCluster="true"; label="mapPartitions"; 424270 [id="node_424270" labelType="html" label="MapPartitionsRDD [424270] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108878 { id="cluster_1108878"; isCluster="true"; label="mapPartitions"; 424271 [id="node_424271" labelType="html" label="MapPartitionsRDD [424271] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 424247->424248; 424261->424262; 424248->424263; 424262->424263; 424263->424264; 424264->424265; 424265->424266; 424266->424267; 424267->424268; 424268->424269; 424269->424270; 424270->424271; }
424246,424247
424260,424261
424271
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