4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1274676 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0 ms
Locality Level Summary:
Process local: 50
Input Size / Records:
46.5 KiB / 240
Associated Job Ids:
41173
DAG Visualization
digraph G { id="graph_1274676"; subgraph graph_stage_1274676 { id="graph_stage_1274676"; isCluster="true"; label="Stage 1274676"; 334583 [id="node_334583" labelType="html" label="SQLExecutionRDD [334583] [Unordered]<br>start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_860550 { id="cluster_860550"; isCluster="true"; label="Exchange"; 334578 [id="node_334578" labelType="html" label="ShuffledRowRDD [334578] [Unordered]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_860546 { id="cluster_860546"; isCluster="true"; label="WholeStageCodegen (2)"; 334579 [id="node_334579" labelType="html" label="MapPartitionsRDD [334579] [Unordered]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_860545 { id="cluster_860545"; isCluster="true"; label="DeserializeToObject"; 334580 [id="node_334580" labelType="html" label="MapPartitionsRDD [334580] [Unordered]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_860544 { id="cluster_860544"; isCluster="true"; label="MapPartitions"; 334581 [id="node_334581" labelType="html" label="MapPartitionsRDD [334581] [Unordered]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_860541 { id="cluster_860541"; isCluster="true"; label="WholeStageCodegen (3)"; 334582 [id="node_334582" labelType="html" label="MapPartitionsRDD [334582] [Unordered]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_860555 { id="cluster_860555"; isCluster="true"; label="map"; 334584 [id="node_334584" labelType="html" label="Delta Table State #7 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/kpi-curve-cache/10000000244/_delta_log [334584] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_860599 { id="cluster_860599"; isCluster="true"; label="WholeStageCodegen (1)"; 334597 [id="node_334597" labelType="html" label="MapPartitionsRDD [334597] [Unordered]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_860603 { id="cluster_860603"; isCluster="true"; label="mapPartitionsInternal"; 334598 [id="node_334598" labelType="html" label="MapPartitionsRDD [334598] [Unordered]<br>start at FileStorageAdapterImpl.java:567}"]; } } 334578->334579; 334579->334580; 334580->334581; 334581->334582; 334582->334583; 334583->334584; 334584->334597; 334597->334598; }
334577,334578
334584
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