4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1341669 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.5 s
Locality Level Summary:
Process local: 2
Input Size / Records:
0.0 B / 2
Shuffle Write Size / Records:
1188.0 B / 2
Associated Job Ids:
47289
DAG Visualization
digraph G { id="graph_1341669"; subgraph graph_stage_1341669 { id="graph_stage_1341669"; isCluster="true"; label="Stage 1341669"; 394624 [id="node_394624" labelType="html" label="SQLExecutionRDD [394624]<br>start at FileStorageAdapterImpl.java:598}"]; subgraph cluster_1039391 { id="cluster_1039391"; isCluster="true"; label="Scan parquet "; 394621 [id="node_394621" labelType="html" label="FileScanRDD [394621]<br>start at FileStorageAdapterImpl.java:598}"]; 394622 [id="node_394622" labelType="html" label="MapPartitionsRDD [394622]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1039388 { id="cluster_1039388"; isCluster="true"; label="WholeStageCodegen (1)"; 394623 [id="node_394623" labelType="html" label="MapPartitionsRDD [394623]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1039406 { id="cluster_1039406"; isCluster="true"; label="WholeStageCodegen (1)"; 394625 [id="node_394625" labelType="html" label="MapPartitionsRDD [394625]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1039405 { id="cluster_1039405"; isCluster="true"; label="HashAggregate"; 394626 [id="node_394626" labelType="html" label="MapPartitionsRDD [394626]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1039404 { id="cluster_1039404"; isCluster="true"; label="Exchange"; 394627 [id="node_394627" labelType="html" label="MapPartitionsRDD [394627]<br>start at FileStorageAdapterImpl.java:598}"]; } } 394621->394622; 394622->394623; 394623->394624; 394624->394625; 394625->394626; 394626->394627; }
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