4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 278656 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
3 s
Locality Level Summary:
Node local: 30
Shuffle Read Size / Records:
193.2 KiB / 1326
Shuffle Write Size / Records:
1860.0 B / 30
Associated Job Ids:
96713
DAG Visualization
digraph G { id="graph_278656"; subgraph graph_stage_278656 { id="graph_stage_278656"; isCluster="true"; label="Stage 278656"; subgraph cluster_1999203 { id="cluster_1999203"; isCluster="true"; label="Exchange"; 789660 [id="node_789660" labelType="html" label="ShuffledRowRDD [789660] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999202 { id="cluster_1999202"; isCluster="true"; label="InMemoryTableScan"; 789661 [id="node_789661" labelType="html" label="MapPartitionsRDD [789661] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 789662 [id="node_789662" labelType="html" label="Exchange hashpartitioning(product#13791301, plant#13791302, 30), REPARTITION_BY_NUM, [plan_id=13567341]\n+- *(1) Scan ExistingRDD[shardId#13791298,worklistShardItemId#13791299L,version#13791300,product#13791301,plant#13791302,periodStart#13791303,periodEnd#13791304,qty#13791305]\n [789662] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 789663 [id="node_789663" labelType="html" label="MapPartitionsRDD [789663] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 789664 [id="node_789664" labelType="html" label="MapPartitionsRDD [789664] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 789665 [id="node_789665" labelType="html" label="MapPartitionsRDD [789665] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999201 { id="cluster_1999201"; isCluster="true"; label="CollectLimit"; 789666 [id="node_789666" labelType="html" label="MapPartitionsRDD [789666] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 789667 [id="node_789667" labelType="html" label="MapPartitionsRDD [789667] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 789660->789661; 789661->789662; 789662->789663; 789663->789664; 789664->789665; 789665->789666; 789666->789667; }
789659,789660
789662
Event Timeline
Enable zooming
Tasks: 30. 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