4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 445620 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
5 s
Locality Level Summary:
Node local: 25
Shuffle Read Size / Records:
2.5 MiB / 11459
Shuffle Write Size / Records:
41.9 KiB / 64
Associated Job Ids:
154626
DAG Visualization
digraph G { id="graph_445620"; subgraph graph_stage_445620 { id="graph_stage_445620"; isCluster="true"; label="Stage 445620"; subgraph cluster_3147377 { id="cluster_3147377"; isCluster="true"; label="Exchange"; 1241697 [id="node_1241697" labelType="html" label="ShuffledRowRDD [1241697] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_3147373 { id="cluster_3147373"; isCluster="true"; label="WholeStageCodegen (41)"; 1241698 [id="node_1241698" labelType="html" label="MapPartitionsRDD [1241698] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_3147383 { id="cluster_3147383"; isCluster="true"; label="Exchange"; 1241699 [id="node_1241699" labelType="html" label="ShuffledRowRDD [1241699] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_3147379 { id="cluster_3147379"; isCluster="true"; label="WholeStageCodegen (42)"; 1241700 [id="node_1241700" labelType="html" label="MapPartitionsRDD [1241700] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_3147366 { id="cluster_3147366"; isCluster="true"; label="WholeStageCodegen (43)"; 1241701 [id="node_1241701" labelType="html" label="ZippedPartitionsRDD2 [1241701] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 1241702 [id="node_1241702" labelType="html" label="MapPartitionsRDD [1241702] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_3147365 { id="cluster_3147365"; isCluster="true"; label="Project"; 1241703 [id="node_1241703" labelType="html" label="MapPartitionsRDD [1241703] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_3147358 { id="cluster_3147358"; isCluster="true"; label="WholeStageCodegen (44)"; 1241704 [id="node_1241704" labelType="html" label="MapPartitionsRDD [1241704] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_3147357 { id="cluster_3147357"; isCluster="true"; label="Exchange"; 1241705 [id="node_1241705" labelType="html" label="MapPartitionsRDD [1241705] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 1241697->1241698; 1241699->1241700; 1241698->1241701; 1241700->1241701; 1241701->1241702; 1241702->1241703; 1241703->1241704; 1241704->1241705; }
1241696,1241697
1241694,1241699
Event Timeline
Enable zooming
Tasks: 25. 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