4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 190796 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2.7 min
Locality Level Summary:
Any: 10; Node local: 20
Shuffle Read Size / Records:
22.7 MiB / 238292
Associated Job Ids:
52704
DAG Visualization
digraph G { id="graph_190796"; subgraph graph_stage_190796 { id="graph_stage_190796"; isCluster="true"; label="Stage 190796"; 425060 [id="node_425060" labelType="html" label="SQLExecutionRDD [425060] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1110687 { id="cluster_1110687"; isCluster="true"; label="Exchange"; 425038 [id="node_425038" labelType="html" label="ShuffledRowRDD [425038] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1110684 { id="cluster_1110684"; isCluster="true"; label="WholeStageCodegen (19)"; 425039 [id="node_425039" labelType="html" label="MapPartitionsRDD [425039] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1110809 { id="cluster_1110809"; isCluster="true"; label="Exchange"; 425052 [id="node_425052" labelType="html" label="ShuffledRowRDD [425052] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1110806 { id="cluster_1110806"; isCluster="true"; label="WholeStageCodegen (22)"; 425053 [id="node_425053" labelType="html" label="MapPartitionsRDD [425053] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1110679 { id="cluster_1110679"; isCluster="true"; label="WholeStageCodegen (23)"; 425054 [id="node_425054" labelType="html" label="ZippedPartitionsRDD2 [425054] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 425055 [id="node_425055" labelType="html" label="MapPartitionsRDD [425055] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1110678 { id="cluster_1110678"; isCluster="true"; label="DeserializeToObject"; 425056 [id="node_425056" labelType="html" label="MapPartitionsRDD [425056] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1110677 { id="cluster_1110677"; isCluster="true"; label="MapPartitions"; 425057 [id="node_425057" labelType="html" label="MapPartitionsRDD [425057] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1110655 { id="cluster_1110655"; isCluster="true"; label="WholeStageCodegen (26)"; 425058 [id="node_425058" labelType="html" label="MapPartitionsRDD [425058] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1110654 { id="cluster_1110654"; isCluster="true"; label="DeserializeToObject"; 425059 [id="node_425059" labelType="html" label="MapPartitionsRDD [425059] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1110822 { id="cluster_1110822"; isCluster="true"; label="mapPartitions"; 425061 [id="node_425061" labelType="html" label="MapPartitionsRDD [425061] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1110823 { id="cluster_1110823"; isCluster="true"; label="mapPartitions"; 425062 [id="node_425062" labelType="html" label="MapPartitionsRDD [425062] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 425038->425039; 425052->425053; 425039->425054; 425053->425054; 425054->425055; 425055->425056; 425056->425057; 425057->425058; 425058->425059; 425059->425060; 425060->425061; 425061->425062; }
425037,425038
425051,425052
425062
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