4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 94380 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.6 s
Locality Level Summary:
Process local: 37
Input Size / Records:
64.3 KiB / 496
Shuffle Write Size / Records:
158.8 KiB / 496
Associated Job Ids:
4946
DAG Visualization
digraph G { id="graph_94380"; subgraph graph_stage_94380 { id="graph_stage_94380"; isCluster="true"; label="Stage 94380"; subgraph cluster_112107 { id="cluster_112107"; isCluster="true"; label="repartition"; 43027 [id="node_43027" labelType="html" label="ShuffledRDD [43027] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43028 [id="node_43028" labelType="html" label="CoalescedRDD [43028] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43029 [id="node_43029" labelType="html" label="MapPartitionsRDD [43029] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112298 { id="cluster_112298"; isCluster="true"; label="map"; 43109 [id="node_43109" labelType="html" label="MapPartitionsRDD [43109] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112397 { id="cluster_112397"; isCluster="true"; label="WholeStageCodegen (5)"; 43140 [id="node_43140" labelType="html" label="MapPartitionsRDD [43140] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112396 { id="cluster_112396"; isCluster="true"; label="Exchange"; 43141 [id="node_43141" labelType="html" label="MapPartitionsRDD [43141] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 43027->43028; 43028->43029; 43029->43109; 43109->43140; 43140->43141; }
43026,43027
43029
43027
43028
43029
43109
43140
43141
Event Timeline
Enable zooming
Tasks: 37. 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