4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 338014 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.5 s
Locality Level Summary:
Process local: 50
Input Size / Records:
218.7 KiB / 1810
Associated Job Ids:
18679
DAG Visualization
digraph G { id="graph_338014"; subgraph graph_stage_338014 { id="graph_stage_338014"; isCluster="true"; label="Stage 338014"; 153625 [id="node_153625" labelType="html" label="SQLExecutionRDD [153625] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_384317 { id="cluster_384317"; isCluster="true"; label="Exchange"; 153620 [id="node_153620" labelType="html" label="ShuffledRowRDD [153620] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384313 { id="cluster_384313"; isCluster="true"; label="WholeStageCodegen (3)"; 153621 [id="node_153621" labelType="html" label="MapPartitionsRDD [153621] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384312 { id="cluster_384312"; isCluster="true"; label="DeserializeToObject"; 153622 [id="node_153622" labelType="html" label="MapPartitionsRDD [153622] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384311 { id="cluster_384311"; isCluster="true"; label="MapPartitions"; 153623 [id="node_153623" labelType="html" label="MapPartitionsRDD [153623] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384308 { id="cluster_384308"; isCluster="true"; label="WholeStageCodegen (4)"; 153624 [id="node_153624" labelType="html" label="MapPartitionsRDD [153624] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384328 { id="cluster_384328"; isCluster="true"; label="map"; 153626 [id="node_153626" labelType="html" label="Delta Table State #56 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/optimal-quantities-cache/10000000532/_delta_log [153626] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384737 { id="cluster_384737"; isCluster="true"; label="WholeStageCodegen (1)"; 153773 [id="node_153773" labelType="html" label="MapPartitionsRDD [153773] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384741 { id="cluster_384741"; isCluster="true"; label="mapPartitionsInternal"; 153774 [id="node_153774" labelType="html" label="MapPartitionsRDD [153774] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } } 153620->153621; 153621->153622; 153622->153623; 153623->153624; 153624->153625; 153625->153626; 153626->153773; 153773->153774; }
153619,153620
153626
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