4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1262992 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Process local: 30
Input Size / Records:
1495.0 B / 4
Shuffle Write Size / Records:
276.0 B / 3
Associated Job Ids:
40880
DAG Visualization
digraph G { id="graph_1262992"; subgraph graph_stage_1262992 { id="graph_stage_1262992"; isCluster="true"; label="Stage 1262992"; 331880 [id="node_331880" labelType="html" label="SQLExecutionRDD [331880] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_853630 { id="cluster_853630"; isCluster="true"; label="Exchange"; 331875 [id="node_331875" labelType="html" label="ShuffledRowRDD [331875] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853629 { id="cluster_853629"; isCluster="true"; label="ObjectHashAggregate"; 331876 [id="node_331876" labelType="html" label="MapPartitionsRDD [331876] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853608 { id="cluster_853608"; isCluster="true"; label="WholeStageCodegen (13)"; 331877 [id="node_331877" labelType="html" label="MapPartitionsRDD [331877] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853600 { id="cluster_853600"; isCluster="true"; label="DeserializeToObject"; 331878 [id="node_331878" labelType="html" label="MapPartitionsRDD [331878] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853594 { id="cluster_853594"; isCluster="true"; label="MapPartitions"; 331879 [id="node_331879" labelType="html" label="MapPartitionsRDD [331879] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853684 { id="cluster_853684"; isCluster="true"; label="mapPartitions"; 331881 [id="node_331881" labelType="html" label="MapPartitionsRDD [331881] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853899 { id="cluster_853899"; isCluster="true"; label="Scan"; 331931 [id="node_331931" labelType="html" label="MapPartitionsRDD [331931] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853888 { id="cluster_853888"; isCluster="true"; label="WholeStageCodegen (1)"; 331932 [id="node_331932" labelType="html" label="MapPartitionsRDD [331932] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853887 { id="cluster_853887"; isCluster="true"; label="Exchange"; 331933 [id="node_331933" labelType="html" label="MapPartitionsRDD [331933] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } } 331875->331876; 331876->331877; 331877->331878; 331878->331879; 331879->331880; 331880->331881; 331881->331931; 331931->331932; 331932->331933; }
331874,331875
331881
331880
331875
331876
331877
331878
331879
331881
331931
331932
331933
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