4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 101065 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1 s
Locality Level Summary:
Node local: 21
Shuffle Read Size / Records:
1578.8 KiB / 868
Shuffle Write Size / Records:
1510.0 KiB / 434
Associated Job Ids:
5483
DAG Visualization
digraph G { id="graph_101065"; subgraph graph_stage_101065 { id="graph_stage_101065"; isCluster="true"; label="Stage 101065"; subgraph cluster_124106 { id="cluster_124106"; isCluster="true"; label="AQEShuffleRead"; 47593 [id="node_47593" labelType="html" label="ShuffledRowRDD [47593] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_124103 { id="cluster_124103"; isCluster="true"; label="WholeStageCodegen (365)"; 47594 [id="node_47594" labelType="html" label="MapPartitionsRDD [47594] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_124111 { id="cluster_124111"; isCluster="true"; label="AQEShuffleRead"; 47595 [id="node_47595" labelType="html" label="ShuffledRowRDD [47595] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_124108 { id="cluster_124108"; isCluster="true"; label="WholeStageCodegen (366)"; 47597 [id="node_47597" labelType="html" label="MapPartitionsRDD [47597] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_124094 { id="cluster_124094"; isCluster="true"; label="WholeStageCodegen (367)"; 47598 [id="node_47598" labelType="html" label="ZippedPartitionsRDD2 [47598] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 47601 [id="node_47601" labelType="html" label="MapPartitionsRDD [47601] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_124093 { id="cluster_124093"; isCluster="true"; label="Exchange"; 47602 [id="node_47602" labelType="html" label="MapPartitionsRDD [47602] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 47593->47594; 47595->47597; 47594->47598; 47597->47598; 47598->47601; 47601->47602; }
47565,47593
47590,47595
Event Timeline
Enable zooming
Tasks: 21. 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