4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 337241 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1 s
Locality Level Summary:
Node local: 30
Shuffle Read Size / Records:
283.0 KiB / 0
Associated Job Ids:
18633
DAG Visualization
digraph G { id="graph_337241"; subgraph graph_stage_337241 { id="graph_stage_337241"; isCluster="true"; label="Stage 337241"; subgraph cluster_383663 { id="cluster_383663"; isCluster="true"; label="Exchange"; 153377 [id="node_153377" labelType="html" label="ShuffledRowRDD [153377] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383659 { id="cluster_383659"; isCluster="true"; label="WholeStageCodegen (2)"; 153378 [id="node_153378" labelType="html" label="MapPartitionsRDD [153378] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383673 { id="cluster_383673"; isCluster="true"; label="Exchange"; 153403 [id="node_153403" labelType="html" label="ShuffledRowRDD [153403] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383669 { id="cluster_383669"; isCluster="true"; label="WholeStageCodegen (6)"; 153404 [id="node_153404" labelType="html" label="MapPartitionsRDD [153404] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383646 { id="cluster_383646"; isCluster="true"; label="WholeStageCodegen (7)"; 153405 [id="node_153405" labelType="html" label="ZippedPartitionsRDD2 [153405] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 153406 [id="node_153406" labelType="html" label="MapPartitionsRDD [153406] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383645 { id="cluster_383645"; isCluster="true"; label="CollectLimit"; 153407 [id="node_153407" labelType="html" label="MapPartitionsRDD [153407] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 153408 [id="node_153408" labelType="html" label="MapPartitionsRDD [153408] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } } 153377->153378; 153403->153404; 153378->153405; 153404->153405; 153405->153406; 153406->153407; 153407->153408; }
153376,153377
153402,153403
153377
153378
153405
153406
153407
153408
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