4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 115293 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0 ms
Locality Level Summary:
Process local: 50
Input Size / Records:
3.4 KiB / 3
Associated Job Ids:
6275
DAG Visualization
digraph G { id="graph_115293"; subgraph graph_stage_115293 { id="graph_stage_115293"; isCluster="true"; label="Stage 115293"; 54920 [id="node_54920" labelType="html" label="SQLExecutionRDD [54920] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; subgraph cluster_142560 { id="cluster_142560"; isCluster="true"; label="Exchange"; 54915 [id="node_54915" labelType="html" label="ShuffledRowRDD [54915] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_142555 { id="cluster_142555"; isCluster="true"; label="WholeStageCodegen (2)"; 54916 [id="node_54916" labelType="html" label="MapPartitionsRDD [54916] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_142554 { id="cluster_142554"; isCluster="true"; label="DeserializeToObject"; 54917 [id="node_54917" labelType="html" label="MapPartitionsRDD [54917] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_142553 { id="cluster_142553"; isCluster="true"; label="MapPartitions"; 54918 [id="node_54918" labelType="html" label="MapPartitionsRDD [54918] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_142550 { id="cluster_142550"; isCluster="true"; label="WholeStageCodegen (3)"; 54919 [id="node_54919" labelType="html" label="MapPartitionsRDD [54919] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_142561 { id="cluster_142561"; isCluster="true"; label="map"; 54921 [id="node_54921" labelType="html" label="Delta Table State #1 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-product-productplant/_delta_log [54921] [Cached] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; } subgraph cluster_143073 { id="cluster_143073"; isCluster="true"; label="WholeStageCodegen (1)"; 55090 [id="node_55090" labelType="html" label="MapPartitionsRDD [55090] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; } subgraph cluster_143077 { id="cluster_143077"; isCluster="true"; label="mapPartitionsInternal"; 55091 [id="node_55091" labelType="html" label="MapPartitionsRDD [55091] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; } } 54915->54916; 54916->54917; 54917->54918; 54918->54919; 54919->54920; 54920->54921; 54921->55090; 55090->55091; }
54914,54915
54921
Event Timeline
Enable zooming
Tasks: 50. 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