4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 2133960 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
15 s
Locality Level Summary:
Process local: 30
Input Size / Records:
0.0 B / 207172
Shuffle Write Size / Records:
7.0 MiB / 207172
Associated Job Ids:
114638
DAG Visualization
digraph G { id="graph_2133960"; subgraph graph_stage_2133960 { id="graph_stage_2133960"; isCluster="true"; label="Stage 2133960"; 942977 [id="node_942977" labelType="html" label="SQLExecutionRDD [942977]<br>start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_2365730 { id="cluster_2365730"; isCluster="true"; label="Scan parquet "; 942974 [id="node_942974" labelType="html" label="FileScanRDD [942974]<br>start at FileStorageAdapterImpl.java:596}"]; 942975 [id="node_942975" labelType="html" label="MapPartitionsRDD [942975]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2365727 { id="cluster_2365727"; isCluster="true"; label="WholeStageCodegen (1)"; 942976 [id="node_942976" labelType="html" label="MapPartitionsRDD [942976]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2365745 { id="cluster_2365745"; isCluster="true"; label="WholeStageCodegen (1)"; 942978 [id="node_942978" labelType="html" label="MapPartitionsRDD [942978]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2365744 { id="cluster_2365744"; isCluster="true"; label="HashAggregate"; 942979 [id="node_942979" labelType="html" label="MapPartitionsRDD [942979]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2365743 { id="cluster_2365743"; isCluster="true"; label="Exchange"; 942980 [id="node_942980" labelType="html" label="MapPartitionsRDD [942980]<br>start at FileStorageAdapterImpl.java:596}"]; } } 942974->942975; 942975->942976; 942976->942977; 942977->942978; 942978->942979; 942979->942980; }
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