4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 99420 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
3 s
Locality Level Summary:
Process local: 26
Input Size / Records:
0.0 B / 394
Shuffle Write Size / Records:
31.1 KiB / 394
Associated Job Ids:
5235
DAG Visualization
digraph G { id="graph_99420"; subgraph graph_stage_99420 { id="graph_stage_99420"; isCluster="true"; label="Stage 99420"; 45812 [id="node_45812" labelType="html" label="SQLExecutionRDD [45812]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_119129 { id="cluster_119129"; isCluster="true"; label="Scan parquet "; 45809 [id="node_45809" labelType="html" label="FileScanRDD [45809]<br>start at FileStorageAdapterImpl.java:171}"]; 45810 [id="node_45810" labelType="html" label="MapPartitionsRDD [45810]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119126 { id="cluster_119126"; isCluster="true"; label="WholeStageCodegen (1)"; 45811 [id="node_45811" labelType="html" label="MapPartitionsRDD [45811]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119133 { id="cluster_119133"; isCluster="true"; label="WholeStageCodegen (1)"; 45813 [id="node_45813" labelType="html" label="MapPartitionsRDD [45813]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119132 { id="cluster_119132"; isCluster="true"; label="Exchange"; 45814 [id="node_45814" labelType="html" label="MapPartitionsRDD [45814]<br>start at FileStorageAdapterImpl.java:171}"]; } } 45809->45810; 45810->45811; 45811->45812; 45812->45813; 45813->45814; }
Event Timeline
Enable zooming
Tasks: 26. 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