4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 117246 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
11 s
Locality Level Summary:
Node local: 20; Process local: 17
Shuffle Read Size / Records:
294.2 KiB / 67
Associated Job Ids:
6450
DAG Visualization
digraph G { id="graph_117246"; subgraph graph_stage_117246 { id="graph_stage_117246"; isCluster="true"; label="Stage 117246"; 56831 [id="node_56831" labelType="html" label="SQLExecutionRDD [56831] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_147398 { id="cluster_147398"; isCluster="true"; label="Exchange"; 56826 [id="node_56826" labelType="html" label="ShuffledRowRDD [56826] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147397 { id="cluster_147397"; isCluster="true"; label="ObjectHashAggregate"; 56827 [id="node_56827" labelType="html" label="MapPartitionsRDD [56827] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147247 { id="cluster_147247"; isCluster="true"; label="WholeStageCodegen (17)"; 56828 [id="node_56828" labelType="html" label="MapPartitionsRDD [56828] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147246 { id="cluster_147246"; isCluster="true"; label="DeserializeToObject"; 56829 [id="node_56829" labelType="html" label="MapPartitionsRDD [56829] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147241 { id="cluster_147241"; isCluster="true"; label="MapPartitions"; 56830 [id="node_56830" labelType="html" label="MapPartitionsRDD [56830] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147484 { id="cluster_147484"; isCluster="true"; label="mapPartitions"; 56832 [id="node_56832" labelType="html" label="MapPartitionsRDD [56832] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 56826->56827; 56827->56828; 56828->56829; 56829->56830; 56830->56831; 56831->56832; }
56825,56826
56832
56831
56826
56827
56828
56829
56830
56832
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