4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 99773 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Process local: 7
Input Size / Records:
0.0 B / 379
Shuffle Write Size / Records:
15.1 KiB / 379
Associated Job Ids:
5257
DAG Visualization
digraph G { id="graph_99773"; subgraph graph_stage_99773 { id="graph_stage_99773"; isCluster="true"; label="Stage 99773"; 46078 [id="node_46078" labelType="html" label="SQLExecutionRDD [46078]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_119752 { id="cluster_119752"; isCluster="true"; label="Scan parquet "; 46075 [id="node_46075" labelType="html" label="FileScanRDD [46075]<br>start at FileStorageAdapterImpl.java:171}"]; 46076 [id="node_46076" labelType="html" label="MapPartitionsRDD [46076]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119749 { id="cluster_119749"; isCluster="true"; label="WholeStageCodegen (1)"; 46077 [id="node_46077" labelType="html" label="MapPartitionsRDD [46077]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119756 { id="cluster_119756"; isCluster="true"; label="WholeStageCodegen (1)"; 46079 [id="node_46079" labelType="html" label="MapPartitionsRDD [46079]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119755 { id="cluster_119755"; isCluster="true"; label="Exchange"; 46080 [id="node_46080" labelType="html" label="MapPartitionsRDD [46080]<br>start at FileStorageAdapterImpl.java:171}"]; } } 46075->46076; 46076->46077; 46077->46078; 46078->46079; 46079->46080; }
Event Timeline
Enable zooming
Tasks: 7. 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