4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 69381 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
12 s
Locality Level Summary:
Node local: 27; Process local: 3
Shuffle Read Size / Records:
70.8 KiB / 109
Associated Job Ids:
25743
DAG Visualization
digraph G { id="graph_69381"; subgraph graph_stage_69381 { id="graph_stage_69381"; isCluster="true"; label="Stage 69381"; 195560 [id="node_195560" labelType="html" label="SQLExecutionRDD [195560] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_515147 { id="cluster_515147"; isCluster="true"; label="Exchange"; 195552 [id="node_195552" labelType="html" label="ShuffledRowRDD [195552] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515146 { id="cluster_515146"; isCluster="true"; label="ObjectHashAggregate"; 195553 [id="node_195553" labelType="html" label="MapPartitionsRDD [195553] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515145 { id="cluster_515145"; isCluster="true"; label="Project"; 195554 [id="node_195554" labelType="html" label="MapPartitionsRDD [195554] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515124 { id="cluster_515124"; isCluster="true"; label="WholeStageCodegen (16)"; 195555 [id="node_195555" labelType="html" label="MapPartitionsRDD [195555] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515123 { id="cluster_515123"; isCluster="true"; label="DeserializeToObject"; 195556 [id="node_195556" labelType="html" label="MapPartitionsRDD [195556] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515122 { id="cluster_515122"; isCluster="true"; label="MapPartitions"; 195557 [id="node_195557" labelType="html" label="MapPartitionsRDD [195557] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515070 { id="cluster_515070"; isCluster="true"; label="WholeStageCodegen (19)"; 195558 [id="node_195558" labelType="html" label="MapPartitionsRDD [195558] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515047 { id="cluster_515047"; isCluster="true"; label="DeserializeToObject"; 195559 [id="node_195559" labelType="html" label="MapPartitionsRDD [195559] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515224 { id="cluster_515224"; isCluster="true"; label="mapPartitions"; 195561 [id="node_195561" labelType="html" label="MapPartitionsRDD [195561] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515225 { id="cluster_515225"; isCluster="true"; label="mapPartitions"; 195562 [id="node_195562" labelType="html" label="MapPartitionsRDD [195562] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 195552->195553; 195553->195554; 195554->195555; 195555->195556; 195556->195557; 195557->195558; 195558->195559; 195559->195560; 195560->195561; 195561->195562; }
195551,195552
195562
Event Timeline
Enable zooming
Tasks: 30. 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