4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1333354 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Process local: 13
Input Size / Records:
0.0 B / 18
Shuffle Write Size / Records:
10.5 KiB / 18
Associated Job Ids:
47117
DAG Visualization
digraph G { id="graph_1333354"; subgraph graph_stage_1333354 { id="graph_stage_1333354"; isCluster="true"; label="Stage 1333354"; 393028 [id="node_393028" labelType="html" label="SQLExecutionRDD [393028]<br>start at FileStorageAdapterImpl.java:598}"]; subgraph cluster_1035124 { id="cluster_1035124"; isCluster="true"; label="Scan parquet "; 393025 [id="node_393025" labelType="html" label="FileScanRDD [393025]<br>start at FileStorageAdapterImpl.java:598}"]; 393026 [id="node_393026" labelType="html" label="MapPartitionsRDD [393026]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035121 { id="cluster_1035121"; isCluster="true"; label="WholeStageCodegen (1)"; 393027 [id="node_393027" labelType="html" label="MapPartitionsRDD [393027]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035139 { id="cluster_1035139"; isCluster="true"; label="WholeStageCodegen (1)"; 393029 [id="node_393029" labelType="html" label="MapPartitionsRDD [393029]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035138 { id="cluster_1035138"; isCluster="true"; label="HashAggregate"; 393030 [id="node_393030" labelType="html" label="MapPartitionsRDD [393030]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035137 { id="cluster_1035137"; isCluster="true"; label="Exchange"; 393031 [id="node_393031" labelType="html" label="MapPartitionsRDD [393031]<br>start at FileStorageAdapterImpl.java:598}"]; } } 393025->393026; 393026->393027; 393027->393028; 393028->393029; 393029->393030; 393030->393031; }
Event Timeline
Enable zooming
Tasks: 13. 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