4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 3726283 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.2 s
Locality Level Summary:
Process local: 50
Input Size / Records:
1947.0 B / 3
Associated Job Ids:
127241
DAG Visualization
digraph G { id="graph_3726283"; subgraph graph_stage_3726283 { id="graph_stage_3726283"; isCluster="true"; label="Stage 3726283"; 1021003 [id="node_1021003" labelType="html" label="SQLExecutionRDD [1021003] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; subgraph cluster_2688171 { id="cluster_2688171"; isCluster="true"; label="Exchange"; 1020998 [id="node_1020998" labelType="html" label="ShuffledRowRDD [1020998] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2688167 { id="cluster_2688167"; isCluster="true"; label="WholeStageCodegen (2)"; 1020999 [id="node_1020999" labelType="html" label="MapPartitionsRDD [1020999] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2688166 { id="cluster_2688166"; isCluster="true"; label="DeserializeToObject"; 1021000 [id="node_1021000" labelType="html" label="MapPartitionsRDD [1021000] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2688165 { id="cluster_2688165"; isCluster="true"; label="MapPartitions"; 1021001 [id="node_1021001" labelType="html" label="MapPartitionsRDD [1021001] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2688147 { id="cluster_2688147"; isCluster="true"; label="WholeStageCodegen (3)"; 1021002 [id="node_1021002" labelType="html" label="MapPartitionsRDD [1021002] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2688176 { id="cluster_2688176"; isCluster="true"; label="map"; 1021004 [id="node_1021004" labelType="html" label="Delta Table State #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/common-data-snapshot/10000001452/_delta_log [1021004] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796847 { id="cluster_2796847"; isCluster="true"; label="WholeStageCodegen (1)"; 1062142 [id="node_1062142" labelType="html" label="MapPartitionsRDD [1062142] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796851 { id="cluster_2796851"; isCluster="true"; label="mapPartitionsInternal"; 1062143 [id="node_1062143" labelType="html" label="MapPartitionsRDD [1062143] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } } 1020998->1020999; 1020999->1021000; 1021000->1021001; 1021001->1021002; 1021002->1021003; 1021003->1021004; 1021004->1062142; 1062142->1062143; }
1020997,1020998
1021004
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