4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 100926 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1 s
Locality Level Summary:
Node local: 1
Shuffle Read Size / Records:
14.7 KiB / 139
Shuffle Write Size / Records:
8.4 KiB / 89
Associated Job Ids:
5435
DAG Visualization
digraph G { id="graph_100926"; subgraph graph_stage_100926 { id="graph_stage_100926"; isCluster="true"; label="Stage 100926"; subgraph cluster_123135 { id="cluster_123135"; isCluster="true"; label="AQEShuffleRead"; 47406 [id="node_47406" labelType="html" label="ShuffledRowRDD [47406] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_123109 { id="cluster_123109"; isCluster="true"; label="WholeStageCodegen (51)"; 47409 [id="node_47409" labelType="html" label="MapPartitionsRDD [47409] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_123107 { id="cluster_123107"; isCluster="true"; label="Generate"; 47412 [id="node_47412" labelType="html" label="MapPartitionsRDD [47412] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_123105 { id="cluster_123105"; isCluster="true"; label="ObjectHashAggregate"; 47414 [id="node_47414" labelType="html" label="MapPartitionsRDD [47414] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_123104 { id="cluster_123104"; isCluster="true"; label="ObjectHashAggregate"; 47415 [id="node_47415" labelType="html" label="MapPartitionsRDD [47415] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_123097 { id="cluster_123097"; isCluster="true"; label="WholeStageCodegen (52)"; 47416 [id="node_47416" labelType="html" label="MapPartitionsRDD [47416] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_123096 { id="cluster_123096"; isCluster="true"; label="Exchange"; 47418 [id="node_47418" labelType="html" label="MapPartitionsRDD [47418] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 47406->47409; 47409->47412; 47412->47414; 47414->47415; 47415->47416; 47416->47418; }
47400,47406
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