4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 102533 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
8 s
Locality Level Summary:
Node local: 37
Shuffle Read Size / Records:
680.0 KiB / 554
Shuffle Write Size / Records:
574.4 KiB / 169
Associated Job Ids:
5696
DAG Visualization
digraph G { id="graph_102533"; subgraph graph_stage_102533 { id="graph_stage_102533"; isCluster="true"; label="Stage 102533"; subgraph cluster_128659 { id="cluster_128659"; isCluster="true"; label="Exchange"; 49245 [id="node_49245" labelType="html" label="ShuffledRowRDD [49245] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128656 { id="cluster_128656"; isCluster="true"; label="WholeStageCodegen (4)"; 49246 [id="node_49246" labelType="html" label="MapPartitionsRDD [49246] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128679 { id="cluster_128679"; isCluster="true"; label="Exchange"; 49256 [id="node_49256" labelType="html" label="ShuffledRowRDD [49256] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128676 { id="cluster_128676"; isCluster="true"; label="WholeStageCodegen (8)"; 49257 [id="node_49257" labelType="html" label="MapPartitionsRDD [49257] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128652 { id="cluster_128652"; isCluster="true"; label="WholeStageCodegen (9)"; 49258 [id="node_49258" labelType="html" label="ZippedPartitionsRDD2 [49258] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 49259 [id="node_49259" labelType="html" label="MapPartitionsRDD [49259] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128651 { id="cluster_128651"; isCluster="true"; label="ObjectHashAggregate"; 49260 [id="node_49260" labelType="html" label="MapPartitionsRDD [49260] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128650 { id="cluster_128650"; isCluster="true"; label="Exchange"; 49261 [id="node_49261" labelType="html" label="MapPartitionsRDD [49261] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } } 49245->49246; 49256->49257; 49246->49258; 49257->49258; 49258->49259; 49259->49260; 49260->49261; }
49244,49245
49255,49256
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