4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 106937 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
6 s
Locality Level Summary:
Node local: 20; Process local: 17
Shuffle Read Size / Records:
160.4 KiB / 104
Shuffle Write Size / Records:
120.7 KiB / 30
Associated Job Ids:
5985
DAG Visualization
digraph G { id="graph_106937"; subgraph graph_stage_106937 { id="graph_stage_106937"; isCluster="true"; label="Stage 106937"; subgraph cluster_135554 { id="cluster_135554"; isCluster="true"; label="Exchange"; 51940 [id="node_51940" labelType="html" label="ShuffledRowRDD [51940] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135551 { id="cluster_135551"; isCluster="true"; label="WholeStageCodegen (4)"; 51941 [id="node_51941" labelType="html" label="MapPartitionsRDD [51941] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135574 { id="cluster_135574"; isCluster="true"; label="Exchange"; 51951 [id="node_51951" labelType="html" label="ShuffledRowRDD [51951] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135571 { id="cluster_135571"; isCluster="true"; label="WholeStageCodegen (8)"; 51952 [id="node_51952" labelType="html" label="MapPartitionsRDD [51952] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135547 { id="cluster_135547"; isCluster="true"; label="WholeStageCodegen (9)"; 51953 [id="node_51953" labelType="html" label="ZippedPartitionsRDD2 [51953] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 51954 [id="node_51954" labelType="html" label="MapPartitionsRDD [51954] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135546 { id="cluster_135546"; isCluster="true"; label="ObjectHashAggregate"; 51955 [id="node_51955" labelType="html" label="MapPartitionsRDD [51955] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135545 { id="cluster_135545"; isCluster="true"; label="Exchange"; 51956 [id="node_51956" labelType="html" label="MapPartitionsRDD [51956] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } } 51940->51941; 51951->51952; 51941->51953; 51952->51953; 51953->51954; 51954->51955; 51955->51956; }
51939,51940
51950,51951
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