4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 339311 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Node local: 60
Shuffle Read Size / Records:
20.8 MiB / 60
Shuffle Write Size / Records:
3.6 KiB / 60
Associated Job Ids:
18695
DAG Visualization
digraph G { id="graph_339311"; subgraph graph_stage_339311 { id="graph_stage_339311"; isCluster="true"; label="Stage 339311"; subgraph cluster_384990 { id="cluster_384990"; isCluster="true"; label="Exchange"; 153898 [id="node_153898" labelType="html" label="ShuffledRowRDD [153898] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384989 { id="cluster_384989"; isCluster="true"; label="Project"; 153899 [id="node_153899" labelType="html" label="MapPartitionsRDD [153899] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384988 { id="cluster_384988"; isCluster="true"; label="InMemoryTableScan"; 153900 [id="node_153900" labelType="html" label="MapPartitionsRDD [153900] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 153901 [id="node_153901" labelType="html" label="Project [shardId#3580449, orderProposals#3592451]\n+- Exchange rangepartitioning(shardId#3580449 ASC NULLS FIRST, resultSeparationId#3592447L ASC NULLS FIRST, 60), REPARTITION_BY_NUM, [plan_id=1029948]\n +- InMemoryTableScan [shardId#3580449, resultSeparationId#3592447L, orderProposals#3592451]\n +- InMemoryRelation [shardId#3580449, resultSeparationId#3592447L, orderProposals#3592451], StorageLevel(disk, memory, 2 replicas)\n +- ObjectHashAggregate(keys=[shardId#3580449, resultSeparationId#3592447L], functions=[collect_list(orderProposal#3584099, 0, 0)], output=[shardId#3580449, resultSeparationId#3592447L, orderProposals#3592451])\n +- Exchange hashpartitioning(shardId#3580449, resultSeparationId#3592447L, 30), ENSURE_REQUIREMENTS, [plan_id=1029905]\n +- ObjectHashAggregate(keys=[shardId#3580449, resultSeparationId#3592447L], functions=[partial_collect_list(orderProposal#3584099, 0, 0)], output=[shardId#3580449, resultSeparationId#3592447L, buf#35924... [153901] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 153902 [id="node_153902" labelType="html" label="MapPartitionsRDD [153902] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 153903 [id="node_153903" labelType="html" label="MapPartitionsRDD [153903] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 153904 [id="node_153904" labelType="html" label="MapPartitionsRDD [153904] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384987 { id="cluster_384987"; isCluster="true"; label="CollectLimit"; 153905 [id="node_153905" labelType="html" label="MapPartitionsRDD [153905] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 153906 [id="node_153906" labelType="html" label="MapPartitionsRDD [153906] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } } 153898->153899; 153899->153900; 153900->153901; 153901->153902; 153902->153903; 153903->153904; 153904->153905; 153905->153906; }
153897,153898
153901
153898
153899
153900
153901
153902
153903
153904
153905
153906
Event Timeline
Enable zooming
Tasks: 60. 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