4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 191142 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Process local: 11
Input Size / Records:
0.0 B / 612
Shuffle Write Size / Records:
170.8 KiB / 612
Associated Job Ids:
52771
DAG Visualization
digraph G { id="graph_191142"; subgraph graph_stage_191142 { id="graph_stage_191142"; isCluster="true"; label="Stage 191142"; subgraph cluster_1113097 { id="cluster_1113097"; isCluster="true"; label="Scan parquet "; 425953 [id="node_425953" labelType="html" label="FileScanRDD [425953]<br>start at FileStorageAdapterImpl.java:179}"]; 425954 [id="node_425954" labelType="html" label="MapPartitionsRDD [425954]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113093 { id="cluster_1113093"; isCluster="true"; label="WholeStageCodegen (1)"; 425955 [id="node_425955" labelType="html" label="MapPartitionsRDD [425955]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113101 { id="cluster_1113101"; isCluster="true"; label="Scan json "; 425956 [id="node_425956" labelType="html" label="FileScanRDD [425956]<br>start at FileStorageAdapterImpl.java:179}"]; 425957 [id="node_425957" labelType="html" label="MapPartitionsRDD [425957]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113098 { id="cluster_1113098"; isCluster="true"; label="WholeStageCodegen (2)"; 425958 [id="node_425958" labelType="html" label="MapPartitionsRDD [425958]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113092 { id="cluster_1113092"; isCluster="true"; label="Union"; 425959 [id="node_425959" labelType="html" label="UnionRDD [425959]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113091 { id="cluster_1113091"; isCluster="true"; label="Exchange"; 425960 [id="node_425960" labelType="html" label="MapPartitionsRDD [425960]<br>start at FileStorageAdapterImpl.java:179}"]; } } 425953->425954; 425954->425955; 425956->425957; 425957->425958; 425955->425959; 425958->425959; 425959->425960; }
Event Timeline
Enable zooming
Tasks: 11. 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