4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1337108 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.2 s
Locality Level Summary:
Node local: 20; Process local: 10
Shuffle Read Size / Records:
144.5 KiB / 381
Shuffle Write Size / Records:
20.4 KiB / 247
Associated Job Ids:
47204
DAG Visualization
digraph G { id="graph_1337108"; subgraph graph_stage_1337108 { id="graph_stage_1337108"; isCluster="true"; label="Stage 1337108"; subgraph cluster_1037320 { id="cluster_1037320"; isCluster="true"; label="Exchange"; 393857 [id="node_393857" labelType="html" label="ShuffledRowRDD [393857] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1037317 { id="cluster_1037317"; isCluster="true"; label="WholeStageCodegen (3)"; 393858 [id="node_393858" labelType="html" label="MapPartitionsRDD [393858] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1037326 { id="cluster_1037326"; isCluster="true"; label="Exchange"; 393861 [id="node_393861" labelType="html" label="ShuffledRowRDD [393861] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1037323 { id="cluster_1037323"; isCluster="true"; label="WholeStageCodegen (2)"; 393862 [id="node_393862" labelType="html" label="MapPartitionsRDD [393862] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1037310 { id="cluster_1037310"; isCluster="true"; label="WholeStageCodegen (4)"; 393863 [id="node_393863" labelType="html" label="ZippedPartitionsRDD2 [393863] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; 393864 [id="node_393864" labelType="html" label="MapPartitionsRDD [393864] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1037309 { id="cluster_1037309"; isCluster="true"; label="Exchange"; 393865 [id="node_393865" labelType="html" label="MapPartitionsRDD [393865] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } } 393857->393858; 393861->393862; 393858->393863; 393862->393863; 393863->393864; 393864->393865; }
393856,393857
393860,393861
393857
393858
393861
393862
393863
393864
393865
Event Timeline
Enable zooming
Tasks: 30. 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