4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 95709 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Node local: 1; Process local: 36
Shuffle Read Size / Records:
4.1 KiB / 1
Associated Job Ids:
4970
DAG Visualization
digraph G { id="graph_95709"; subgraph graph_stage_95709 { id="graph_stage_95709"; isCluster="true"; label="Stage 95709"; 43494 [id="node_43494" labelType="html" label="SQLExecutionRDD [43494] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_113088 { id="cluster_113088"; isCluster="true"; label="Exchange"; 43489 [id="node_43489" labelType="html" label="ShuffledRowRDD [43489] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113087 { id="cluster_113087"; isCluster="true"; label="ObjectHashAggregate"; 43490 [id="node_43490" labelType="html" label="MapPartitionsRDD [43490] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112937 { id="cluster_112937"; isCluster="true"; label="WholeStageCodegen (17)"; 43491 [id="node_43491" labelType="html" label="MapPartitionsRDD [43491] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112936 { id="cluster_112936"; isCluster="true"; label="DeserializeToObject"; 43492 [id="node_43492" labelType="html" label="MapPartitionsRDD [43492] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112931 { id="cluster_112931"; isCluster="true"; label="MapPartitions"; 43493 [id="node_43493" labelType="html" label="MapPartitionsRDD [43493] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113174 { id="cluster_113174"; isCluster="true"; label="mapPartitions"; 43495 [id="node_43495" labelType="html" label="MapPartitionsRDD [43495] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 43489->43490; 43490->43491; 43491->43492; 43492->43493; 43493->43494; 43494->43495; }
43488,43489
43495
43494
43489
43490
43491
43492
43493
43495
Event Timeline
Enable zooming
Tasks: 37. 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