4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 339856 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.3 s
Locality Level Summary:
Process local: 60
Input Size / Records:
20.8 MiB / 60
Shuffle Write Size / Records:
3.6 KiB / 60
Associated Job Ids:
18703
DAG Visualization
digraph G { id="graph_339856"; subgraph graph_stage_339856 { id="graph_stage_339856"; isCluster="true"; label="Stage 339856"; 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}"]; } subgraph cluster_385169 { id="cluster_385169"; isCluster="true"; label="InMemoryTableScan"; 153964 [id="node_153964" labelType="html" label="MapPartitionsRDD [153964] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 153965 [id="node_153965" labelType="html" label="MapPartitionsRDD [153965] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 153966 [id="node_153966" labelType="html" label="MapPartitionsRDD [153966] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385168 { id="cluster_385168"; isCluster="true"; label="CollectLimit"; 153967 [id="node_153967" labelType="html" label="MapPartitionsRDD [153967] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 153968 [id="node_153968" labelType="html" label="MapPartitionsRDD [153968] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } } 153898->153899; 153899->153900; 153900->153901; 153901->153964; 153964->153965; 153965->153966; 153966->153967; 153967->153968; }
153897,153898
153901
153898
153899
153900
153901
153964
153965
153966
153967
153968
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