4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 101260 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.6 s
Locality Level Summary:
Node local: 1
Shuffle Read Size / Records:
884.0 B / 11
Shuffle Write Size / Records:
2.9 KiB / 11
Associated Job Ids:
5556
DAG Visualization
digraph G { id="graph_101260"; subgraph graph_stage_101260 { id="graph_stage_101260"; isCluster="true"; label="Stage 101260"; subgraph cluster_125218 { id="cluster_125218"; isCluster="true"; label="AQEShuffleRead"; 47911 [id="node_47911" labelType="html" label="ShuffledRowRDD [47911] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125215 { id="cluster_125215"; isCluster="true"; label="WholeStageCodegen (69)"; 47912 [id="node_47912" labelType="html" label="MapPartitionsRDD [47912] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125214 { id="cluster_125214"; isCluster="true"; label="Window"; 47913 [id="node_47913" labelType="html" label="MapPartitionsRDD [47913] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125213 { id="cluster_125213"; isCluster="true"; label="Project"; 47914 [id="node_47914" labelType="html" label="MapPartitionsRDD [47914] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125212 { id="cluster_125212"; isCluster="true"; label="ObjectHashAggregate"; 47915 [id="node_47915" labelType="html" label="MapPartitionsRDD [47915] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125211 { id="cluster_125211"; isCluster="true"; label="Exchange"; 47916 [id="node_47916" labelType="html" label="MapPartitionsRDD [47916] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 47911->47912; 47912->47913; 47913->47914; 47914->47915; 47915->47916; }
47902,47911
Event Timeline
Enable zooming
Tasks: 1. 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