4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1255853 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Process local: 30
Input Size / Records:
1344.0 B / 4
Associated Job Ids:
40733
DAG Visualization
digraph G { id="graph_1255853"; subgraph graph_stage_1255853 { id="graph_stage_1255853"; isCluster="true"; label="Stage 1255853"; 330593 [id="node_330593" labelType="html" label="SQLExecutionRDD [330593] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_850373 { id="cluster_850373"; isCluster="true"; label="Exchange"; 330588 [id="node_330588" labelType="html" label="ShuffledRowRDD [330588] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_850372 { id="cluster_850372"; isCluster="true"; label="ObjectHashAggregate"; 330589 [id="node_330589" labelType="html" label="MapPartitionsRDD [330589] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_850351 { id="cluster_850351"; isCluster="true"; label="WholeStageCodegen (13)"; 330590 [id="node_330590" labelType="html" label="MapPartitionsRDD [330590] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_850343 { id="cluster_850343"; isCluster="true"; label="DeserializeToObject"; 330591 [id="node_330591" labelType="html" label="MapPartitionsRDD [330591] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_850337 { id="cluster_850337"; isCluster="true"; label="MapPartitions"; 330592 [id="node_330592" labelType="html" label="MapPartitionsRDD [330592] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_850427 { id="cluster_850427"; isCluster="true"; label="mapPartitions"; 330594 [id="node_330594" labelType="html" label="MapPartitionsRDD [330594] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_850562 { id="cluster_850562"; isCluster="true"; label="Scan"; 330624 [id="node_330624" labelType="html" label="MapPartitionsRDD [330624] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_850551 { id="cluster_850551"; isCluster="true"; label="WholeStageCodegen (1)"; 330625 [id="node_330625" labelType="html" label="MapPartitionsRDD [330625] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_850550 { id="cluster_850550"; isCluster="true"; label="Exchange"; 330626 [id="node_330626" labelType="html" label="MapPartitionsRDD [330626] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } } 330588->330589; 330589->330590; 330590->330591; 330591->330592; 330592->330593; 330593->330594; 330594->330624; 330624->330625; 330625->330626; }
330587,330588
330594
330593
330588
330589
330590
330591
330592
330594
330624
330625
330626
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