4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 94239 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.4 s
Locality Level Summary:
Process local: 2
Input Size / Records:
0.0 B / 6
Shuffle Write Size / Records:
630.0 B / 6
Associated Job Ids:
4940
DAG Visualization
digraph G { id="graph_94239"; subgraph graph_stage_94239 { id="graph_stage_94239"; isCluster="true"; label="Stage 94239"; 43087 [id="node_43087" labelType="html" label="SQLExecutionRDD [43087]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_112255 { id="cluster_112255"; isCluster="true"; label="Scan parquet "; 43084 [id="node_43084" labelType="html" label="FileScanRDD [43084]<br>start at FileStorageAdapterImpl.java:171}"]; 43085 [id="node_43085" labelType="html" label="MapPartitionsRDD [43085]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112252 { id="cluster_112252"; isCluster="true"; label="WholeStageCodegen (1)"; 43086 [id="node_43086" labelType="html" label="MapPartitionsRDD [43086]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112259 { id="cluster_112259"; isCluster="true"; label="WholeStageCodegen (1)"; 43088 [id="node_43088" labelType="html" label="MapPartitionsRDD [43088]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112258 { id="cluster_112258"; isCluster="true"; label="Exchange"; 43089 [id="node_43089" labelType="html" label="MapPartitionsRDD [43089]<br>start at FileStorageAdapterImpl.java:171}"]; } } 43084->43085; 43085->43086; 43086->43087; 43087->43088; 43088->43089; }
Event Timeline
Enable zooming
Tasks: 2. 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