4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 446056 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
3 s
Locality Level Summary:
Node local: 10; Process local: 10
Shuffle Read Size / Records:
11.7 KiB / 36
Shuffle Write Size / Records:
9.2 KiB / 15
Associated Job Ids:
154778
DAG Visualization
digraph G { id="graph_446056"; subgraph graph_stage_446056 { id="graph_stage_446056"; isCluster="true"; label="Stage 446056"; subgraph cluster_3150499 { id="cluster_3150499"; isCluster="true"; label="Exchange"; 1242741 [id="node_1242741" labelType="html" label="ShuffledRowRDD [1242741] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150496 { id="cluster_3150496"; isCluster="true"; label="WholeStageCodegen (6)"; 1242742 [id="node_1242742" labelType="html" label="MapPartitionsRDD [1242742] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150538 { id="cluster_3150538"; isCluster="true"; label="Exchange"; 1242752 [id="node_1242752" labelType="html" label="ShuffledRowRDD [1242752] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150535 { id="cluster_3150535"; isCluster="true"; label="WholeStageCodegen (12)"; 1242753 [id="node_1242753" labelType="html" label="MapPartitionsRDD [1242753] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150492 { id="cluster_3150492"; isCluster="true"; label="WholeStageCodegen (13)"; 1242754 [id="node_1242754" labelType="html" label="ZippedPartitionsRDD2 [1242754] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 1242755 [id="node_1242755" labelType="html" label="MapPartitionsRDD [1242755] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150491 { id="cluster_3150491"; isCluster="true"; label="ObjectHashAggregate"; 1242756 [id="node_1242756" labelType="html" label="MapPartitionsRDD [1242756] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150490 { id="cluster_3150490"; isCluster="true"; label="Exchange"; 1242757 [id="node_1242757" labelType="html" label="MapPartitionsRDD [1242757] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 1242741->1242742; 1242752->1242753; 1242742->1242754; 1242753->1242754; 1242754->1242755; 1242755->1242756; 1242756->1242757; }
1242740,1242741
1242751,1242752
Event Timeline
Enable zooming
Tasks: 20. 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