4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 55 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.7 s
Locality Level Summary:
Process local: 25
Associated Job Ids:
28
DAG Visualization
digraph G { id="graph_55"; subgraph graph_stage_55 { id="graph_stage_55"; isCluster="true"; label="Stage 55"; subgraph cluster_429 { id="cluster_429"; isCluster="true"; label="Exchange"; 188 [id="node_188" labelType="html" label="ShuffledRowRDD [188] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_428 { id="cluster_428"; isCluster="true"; label="InMemoryTableScan"; 189 [id="node_189" labelType="html" label="MapPartitionsRDD [189] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 190 [id="node_190" labelType="html" label="Exchange hashpartitioning(product#1544, plant#1545, 25), REPARTITION_BY_NUM, [plan_id=1315]\n+- *(1) Scan ExistingRDD[shardId#1541,worklistShardItemId#1542L,version#1543,product#1544,plant#1545,periodStart#1546,periodEnd#1547,qty#1548]\n [190] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 191 [id="node_191" labelType="html" label="MapPartitionsRDD [191] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 192 [id="node_192" labelType="html" label="MapPartitionsRDD [192] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 193 [id="node_193" labelType="html" label="MapPartitionsRDD [193] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_427 { id="cluster_427"; isCluster="true"; label="CollectLimit"; 194 [id="node_194" labelType="html" label="MapPartitionsRDD [194] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 195 [id="node_195" labelType="html" label="MapPartitionsRDD [195] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } } 188->189; 189->190; 190->191; 191->192; 192->193; 193->194; 194->195; }
187,188
190
Event Timeline
Enable zooming
Tasks: 25. 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