4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 69380 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
4 s
Locality Level Summary:
Node local: 30
Shuffle Read Size / Records:
86.9 KiB / 290
Shuffle Write Size / Records:
70.8 KiB / 109
Associated Job Ids:
25743
DAG Visualization
digraph G { id="graph_69380"; subgraph graph_stage_69380 { id="graph_stage_69380"; isCluster="true"; label="Stage 69380"; subgraph cluster_515156 { id="cluster_515156"; isCluster="true"; label="Exchange"; 195535 [id="node_195535" labelType="html" label="ShuffledRowRDD [195535] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515153 { id="cluster_515153"; isCluster="true"; label="WholeStageCodegen (6)"; 195536 [id="node_195536" labelType="html" label="MapPartitionsRDD [195536] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515195 { id="cluster_515195"; isCluster="true"; label="Exchange"; 195546 [id="node_195546" labelType="html" label="ShuffledRowRDD [195546] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515192 { id="cluster_515192"; isCluster="true"; label="WholeStageCodegen (12)"; 195547 [id="node_195547" labelType="html" label="MapPartitionsRDD [195547] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515149 { id="cluster_515149"; isCluster="true"; label="WholeStageCodegen (13)"; 195548 [id="node_195548" labelType="html" label="ZippedPartitionsRDD2 [195548] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 195549 [id="node_195549" labelType="html" label="MapPartitionsRDD [195549] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515148 { id="cluster_515148"; isCluster="true"; label="ObjectHashAggregate"; 195550 [id="node_195550" labelType="html" label="MapPartitionsRDD [195550] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515147 { id="cluster_515147"; isCluster="true"; label="Exchange"; 195551 [id="node_195551" labelType="html" label="MapPartitionsRDD [195551] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 195535->195536; 195546->195547; 195536->195548; 195547->195548; 195548->195549; 195549->195550; 195550->195551; }
195534,195535
195545,195546
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