4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 101601 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
13 s
Locality Level Summary:
Node local: 22; Process local: 15
Shuffle Read Size / Records:
1601.9 KiB / 280
Associated Job Ids:
5632
DAG Visualization
digraph G { id="graph_101601"; subgraph graph_stage_101601 { id="graph_stage_101601"; isCluster="true"; label="Stage 101601"; 48499 [id="node_48499" labelType="html" label="SQLExecutionRDD [48499] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_126773 { id="cluster_126773"; isCluster="true"; label="Exchange"; 48494 [id="node_48494" labelType="html" label="ShuffledRowRDD [48494] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126772 { id="cluster_126772"; isCluster="true"; label="ObjectHashAggregate"; 48495 [id="node_48495" labelType="html" label="MapPartitionsRDD [48495] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126622 { id="cluster_126622"; isCluster="true"; label="WholeStageCodegen (17)"; 48496 [id="node_48496" labelType="html" label="MapPartitionsRDD [48496] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126621 { id="cluster_126621"; isCluster="true"; label="DeserializeToObject"; 48497 [id="node_48497" labelType="html" label="MapPartitionsRDD [48497] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126616 { id="cluster_126616"; isCluster="true"; label="MapPartitions"; 48498 [id="node_48498" labelType="html" label="MapPartitionsRDD [48498] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126859 { id="cluster_126859"; isCluster="true"; label="mapPartitions"; 48500 [id="node_48500" labelType="html" label="MapPartitionsRDD [48500] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 48494->48495; 48495->48496; 48496->48497; 48497->48498; 48498->48499; 48499->48500; }
48493,48494
48500
48499
48494
48495
48496
48497
48498
48500
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