4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 762 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.3 s
Locality Level Summary:
Process local: 50
Input Size / Records:
3.7 KiB / 4
Associated Job Ids:
369
DAG Visualization
digraph G { id="graph_762"; subgraph graph_stage_762 { id="graph_stage_762"; isCluster="true"; label="Stage 762"; 1417 [id="node_1417" labelType="html" label="SQLExecutionRDD [1417] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; subgraph cluster_4315 { id="cluster_4315"; isCluster="true"; label="Exchange"; 1412 [id="node_1412" labelType="html" label="ShuffledRowRDD [1412] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_4310 { id="cluster_4310"; isCluster="true"; label="WholeStageCodegen (2)"; 1413 [id="node_1413" labelType="html" label="MapPartitionsRDD [1413] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_4309 { id="cluster_4309"; isCluster="true"; label="DeserializeToObject"; 1414 [id="node_1414" labelType="html" label="MapPartitionsRDD [1414] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_4308 { id="cluster_4308"; isCluster="true"; label="MapPartitions"; 1415 [id="node_1415" labelType="html" label="MapPartitionsRDD [1415] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_4305 { id="cluster_4305"; isCluster="true"; label="WholeStageCodegen (3)"; 1416 [id="node_1416" labelType="html" label="MapPartitionsRDD [1416] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_4316 { id="cluster_4316"; isCluster="true"; label="map"; 1418 [id="node_1418" labelType="html" label="Delta Table State #2 - hdlfs://9b46f9d5-066e-49af-bc5c-7af37534ca4d.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-product-productplant/_delta_log [1418] [Cached] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; } subgraph cluster_6411 { id="cluster_6411"; isCluster="true"; label="WholeStageCodegen (1)"; 1913 [id="node_1913" labelType="html" label="MapPartitionsRDD [1913] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; } subgraph cluster_6415 { id="cluster_6415"; isCluster="true"; label="mapPartitionsInternal"; 1914 [id="node_1914" labelType="html" label="MapPartitionsRDD [1914] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; } } 1412->1413; 1413->1414; 1414->1415; 1415->1416; 1416->1417; 1417->1418; 1418->1913; 1913->1914; }
1411,1412
1418
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