4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 94378 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
4 s
Locality Level Summary:
Process local: 37
Input Size / Records:
64.3 KiB / 496
Associated Job Ids:
4946
DAG Visualization
digraph G { id="graph_94378"; subgraph graph_stage_94378 { id="graph_stage_94378"; isCluster="true"; label="Stage 94378"; 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_112366 { id="cluster_112366"; isCluster="true"; label="WholeStageCodegen (2)"; 43133 [id="node_43133" labelType="html" label="MapPartitionsRDD [43133] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112365 { id="cluster_112365"; isCluster="true"; label="Exchange"; 43134 [id="node_43134" labelType="html" label="MapPartitionsRDD [43134] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 43027->43028; 43028->43029; 43029->43109; 43109->43133; 43133->43134; }
43026,43027
43029
43027
43028
43029
43109
43133
43134
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