4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 446288 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
8 s
Locality Level Summary:
Node local: 19; Process local: 1
Shuffle Read Size / Records:
70.2 KiB / 123
Associated Job Ids:
154855
DAG Visualization
digraph G { id="graph_446288"; subgraph graph_stage_446288 { id="graph_stage_446288"; isCluster="true"; label="Stage 446288"; 1243450 [id="node_1243450" labelType="html" label="SQLExecutionRDD [1243450] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_3152160 { id="cluster_3152160"; isCluster="true"; label="Exchange"; 1243442 [id="node_1243442" labelType="html" label="ShuffledRowRDD [1243442] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152159 { id="cluster_3152159"; isCluster="true"; label="ObjectHashAggregate"; 1243443 [id="node_1243443" labelType="html" label="MapPartitionsRDD [1243443] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152158 { id="cluster_3152158"; isCluster="true"; label="Project"; 1243444 [id="node_1243444" labelType="html" label="MapPartitionsRDD [1243444] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152151 { id="cluster_3152151"; isCluster="true"; label="WholeStageCodegen (16)"; 1243445 [id="node_1243445" labelType="html" label="MapPartitionsRDD [1243445] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152150 { id="cluster_3152150"; isCluster="true"; label="DeserializeToObject"; 1243446 [id="node_1243446" labelType="html" label="MapPartitionsRDD [1243446] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152149 { id="cluster_3152149"; isCluster="true"; label="MapPartitions"; 1243447 [id="node_1243447" labelType="html" label="MapPartitionsRDD [1243447] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152081 { id="cluster_3152081"; isCluster="true"; label="WholeStageCodegen (19)"; 1243448 [id="node_1243448" labelType="html" label="MapPartitionsRDD [1243448] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152060 { id="cluster_3152060"; isCluster="true"; label="DeserializeToObject"; 1243449 [id="node_1243449" labelType="html" label="MapPartitionsRDD [1243449] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152237 { id="cluster_3152237"; isCluster="true"; label="mapPartitions"; 1243451 [id="node_1243451" labelType="html" label="MapPartitionsRDD [1243451] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152238 { id="cluster_3152238"; isCluster="true"; label="mapPartitions"; 1243452 [id="node_1243452" labelType="html" label="MapPartitionsRDD [1243452] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 1243442->1243443; 1243443->1243444; 1243444->1243445; 1243445->1243446; 1243446->1243447; 1243447->1243448; 1243448->1243449; 1243449->1243450; 1243450->1243451; 1243451->1243452; }
1243441,1243442
1243452
Event Timeline
Enable zooming
Tasks: 20. 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