3.5.5
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 315 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.3 s
Locality Level Summary:
Process local: 5
Input Size / Records:
0.0 B / 27
Associated Job Ids:
170
DAG Visualization
digraph G { subgraph clusterstage_315 { label="Stage 315"; subgraph cluster2288 { label="Scan parquet "; 860 [labelType="html" label="FileScanRDD [860]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 861 [labelType="html" label="MapPartitionsRDD [861]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster2281 { label="WholeStageCodegen (1)"; 862 [labelType="html" label="MapPartitionsRDD [862]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster2293 { label="Scan json "; 863 [labelType="html" label="FileScanRDD [863]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 864 [labelType="html" label="MapPartitionsRDD [864]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster2289 { label="WholeStageCodegen (2)"; 865 [labelType="html" label="MapPartitionsRDD [865]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster2280 { label="Union"; 866 [labelType="html" label="UnionRDD [866]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster2294 { label="mapPartitionsInternal"; 867 [labelType="html" label="MapPartitionsRDD [867]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 860->861; 861->862; 863->864; 864->865; 862->866; 865->866; 866->867; }
Event Timeline
Enable zooming
Tasks: 5. 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