4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 445574 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0 ms
Locality Level Summary:
Process local: 50
Input Size / Records:
3.0 KiB / 3
Associated Job Ids:
154593
DAG Visualization
digraph G { id="graph_445574"; subgraph graph_stage_445574 { id="graph_stage_445574"; isCluster="true"; label="Stage 445574"; 1241505 [id="node_1241505" labelType="html" label="SQLExecutionRDD [1241505] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; subgraph cluster_3146828 { id="cluster_3146828"; isCluster="true"; label="Exchange"; 1241500 [id="node_1241500" labelType="html" label="ShuffledRowRDD [1241500] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_3146823 { id="cluster_3146823"; isCluster="true"; label="WholeStageCodegen (2)"; 1241501 [id="node_1241501" labelType="html" label="MapPartitionsRDD [1241501] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_3146822 { id="cluster_3146822"; isCluster="true"; label="DeserializeToObject"; 1241502 [id="node_1241502" labelType="html" label="MapPartitionsRDD [1241502] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_3146821 { id="cluster_3146821"; isCluster="true"; label="MapPartitions"; 1241503 [id="node_1241503" labelType="html" label="MapPartitionsRDD [1241503] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_3146818 { id="cluster_3146818"; isCluster="true"; label="WholeStageCodegen (3)"; 1241504 [id="node_1241504" labelType="html" label="MapPartitionsRDD [1241504] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_3146829 { id="cluster_3146829"; isCluster="true"; label="map"; 1241506 [id="node_1241506" labelType="html" label="Delta Table State #4 - hdlfs://f1cc4c74-cdd4-440e-abc7-4e0157628b42.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-plant-plant/_delta_log [1241506] [Cached] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; } subgraph cluster_3147045 { id="cluster_3147045"; isCluster="true"; label="WholeStageCodegen (1)"; 1241570 [id="node_1241570" labelType="html" label="MapPartitionsRDD [1241570] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; } subgraph cluster_3147049 { id="cluster_3147049"; isCluster="true"; label="mapPartitionsInternal"; 1241571 [id="node_1241571" labelType="html" label="MapPartitionsRDD [1241571] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; } } 1241500->1241501; 1241501->1241502; 1241502->1241503; 1241503->1241504; 1241504->1241505; 1241505->1241506; 1241506->1241570; 1241570->1241571; }
1241499,1241500
1241506
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