4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 241122 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
46 s
Locality Level Summary:
Process local: 36
Input Size / Records:
0.0 B / 481520
Shuffle Write Size / Records:
14.0 MiB / 481520
Associated Job Ids:
66409
DAG Visualization
digraph G { id="graph_241122"; subgraph graph_stage_241122 { id="graph_stage_241122"; isCluster="true"; label="Stage 241122"; subgraph cluster_1409091 { id="cluster_1409091"; isCluster="true"; label="Scan parquet "; 539517 [id="node_539517" labelType="html" label="FileScanRDD [539517]<br>start at FileStorageAdapterImpl.java:179}"]; 539518 [id="node_539518" labelType="html" label="MapPartitionsRDD [539518]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409087 { id="cluster_1409087"; isCluster="true"; label="WholeStageCodegen (12)"; 539519 [id="node_539519" labelType="html" label="MapPartitionsRDD [539519]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409086 { id="cluster_1409086"; isCluster="true"; label="Exchange"; 539520 [id="node_539520" labelType="html" label="MapPartitionsRDD [539520]<br>start at FileStorageAdapterImpl.java:179}"]; } } 539517->539518; 539518->539519; 539519->539520; }
Event Timeline
Enable zooming
Tasks: 36. 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