4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 1001 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.5 s
Locality Level Summary:
Process local: 8
Associated Job Ids:
457
DAG Visualization
digraph G { id="graph_1001"; subgraph graph_stage_1001 { id="graph_stage_1001"; isCluster="true"; label="Stage 1001"; subgraph cluster_8127 { id="cluster_8127"; isCluster="true"; label="Exchange"; 2622 [id="node_2622" labelType="html" label="ShuffledRowRDD [2622] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_8126 { id="cluster_8126"; isCluster="true"; label="InMemoryTableScan"; 2623 [id="node_2623" labelType="html" label="MapPartitionsRDD [2623] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 2624 [id="node_2624" labelType="html" label="Exchange hashpartitioning(product#49874, plant#49875, 8), REPARTITION_BY_NUM, [plan_id=218008]\n+- *(1) Scan ExistingRDD[shardId#49871,worklistShardItemId#49872L,version#49873,product#49874,plant#49875,periodStart#49876,periodEnd#49877,qty#49878]\n [2624] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 2625 [id="node_2625" labelType="html" label="MapPartitionsRDD [2625] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 2626 [id="node_2626" labelType="html" label="MapPartitionsRDD [2626] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 2627 [id="node_2627" labelType="html" label="MapPartitionsRDD [2627] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_8125 { id="cluster_8125"; isCluster="true"; label="CollectLimit"; 2628 [id="node_2628" labelType="html" label="MapPartitionsRDD [2628] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 2629 [id="node_2629" labelType="html" label="MapPartitionsRDD [2629] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 2622->2623; 2623->2624; 2624->2625; 2625->2626; 2626->2627; 2627->2628; 2628->2629; }
2621,2622
2624
Event Timeline
Enable zooming
Tasks: 8. 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