4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 1094 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.2 s
Locality Level Summary:
Process local: 1
Input Size / Records:
0.0 B / 1518
Shuffle Write Size / Records:
53.5 KiB / 1518
Associated Job Ids:
512
DAG Visualization
digraph G { id="graph_1094"; subgraph graph_stage_1094 { id="graph_stage_1094"; isCluster="true"; label="Stage 1094"; subgraph cluster_8869 { id="cluster_8869"; isCluster="true"; label="Scan parquet "; 2876 [id="node_2876" labelType="html" label="FileScanRDD [2876]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 2878 [id="node_2878" labelType="html" label="MapPartitionsRDD [2878]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_8848 { id="cluster_8848"; isCluster="true"; label="WholeStageCodegen (2)"; 2883 [id="node_2883" labelType="html" label="MapPartitionsRDD [2883]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_8847 { id="cluster_8847"; isCluster="true"; label="Exchange"; 2885 [id="node_2885" labelType="html" label="MapPartitionsRDD [2885]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 2887 [id="node_2887" labelType="html" label="MapPartitionsRDD [2887]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 2876->2878; 2878->2883; 2883->2885; 2885->2887; }
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