4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 97365 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
5 s
Locality Level Summary:
Node local: 2; Process local: 35
Shuffle Read Size / Records:
8.3 KiB / 6
Shuffle Write Size / Records:
7.9 KiB / 2
Associated Job Ids:
5057
DAG Visualization
digraph G { id="graph_97365"; subgraph graph_stage_97365 { id="graph_stage_97365"; isCluster="true"; label="Stage 97365"; subgraph cluster_115661 { id="cluster_115661"; isCluster="true"; label="Exchange"; 44528 [id="node_44528" labelType="html" label="ShuffledRowRDD [44528] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115658 { id="cluster_115658"; isCluster="true"; label="WholeStageCodegen (4)"; 44529 [id="node_44529" labelType="html" label="MapPartitionsRDD [44529] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115681 { id="cluster_115681"; isCluster="true"; label="Exchange"; 44539 [id="node_44539" labelType="html" label="ShuffledRowRDD [44539] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115678 { id="cluster_115678"; isCluster="true"; label="WholeStageCodegen (8)"; 44540 [id="node_44540" labelType="html" label="MapPartitionsRDD [44540] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115654 { id="cluster_115654"; isCluster="true"; label="WholeStageCodegen (9)"; 44541 [id="node_44541" labelType="html" label="ZippedPartitionsRDD2 [44541] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 44542 [id="node_44542" labelType="html" label="MapPartitionsRDD [44542] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115653 { id="cluster_115653"; isCluster="true"; label="ObjectHashAggregate"; 44543 [id="node_44543" labelType="html" label="MapPartitionsRDD [44543] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115652 { id="cluster_115652"; isCluster="true"; label="Exchange"; 44544 [id="node_44544" labelType="html" label="MapPartitionsRDD [44544] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } } 44528->44529; 44539->44540; 44529->44541; 44540->44541; 44541->44542; 44542->44543; 44543->44544; }
44527,44528
44538,44539
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