4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 100351 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
5 s
Locality Level Summary:
Node local: 6; Process local: 31
Shuffle Read Size / Records:
42.6 KiB / 10
Associated Job Ids:
5307
DAG Visualization
digraph G { id="graph_100351"; subgraph graph_stage_100351 { id="graph_stage_100351"; isCluster="true"; label="Stage 100351"; 46747 [id="node_46747" labelType="html" label="SQLExecutionRDD [46747] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_121204 { id="cluster_121204"; isCluster="true"; label="Exchange"; 46742 [id="node_46742" labelType="html" label="ShuffledRowRDD [46742] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121203 { id="cluster_121203"; isCluster="true"; label="ObjectHashAggregate"; 46743 [id="node_46743" labelType="html" label="MapPartitionsRDD [46743] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121053 { id="cluster_121053"; isCluster="true"; label="WholeStageCodegen (17)"; 46744 [id="node_46744" labelType="html" label="MapPartitionsRDD [46744] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121052 { id="cluster_121052"; isCluster="true"; label="DeserializeToObject"; 46745 [id="node_46745" labelType="html" label="MapPartitionsRDD [46745] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121047 { id="cluster_121047"; isCluster="true"; label="MapPartitions"; 46746 [id="node_46746" labelType="html" label="MapPartitionsRDD [46746] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121290 { id="cluster_121290"; isCluster="true"; label="mapPartitions"; 46748 [id="node_46748" labelType="html" label="MapPartitionsRDD [46748] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 46742->46743; 46743->46744; 46744->46745; 46745->46746; 46746->46747; 46747->46748; }
46741,46742
46748
46747
46742
46743
46744
46745
46746
46748
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