4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1035894 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Node local: 30
Shuffle Read Size / Records:
353.1 KiB / 0
Associated Job Ids:
52734
DAG Visualization
digraph G { id="graph_1035894"; subgraph graph_stage_1035894 { id="graph_stage_1035894"; isCluster="true"; label="Stage 1035894"; subgraph cluster_1088959 { id="cluster_1088959"; isCluster="true"; label="Exchange"; 434649 [id="node_434649" labelType="html" label="ShuffledRowRDD [434649] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1088956 { id="cluster_1088956"; isCluster="true"; label="WholeStageCodegen (2)"; 434650 [id="node_434650" labelType="html" label="MapPartitionsRDD [434650] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1088969 { id="cluster_1088969"; isCluster="true"; label="Exchange"; 434658 [id="node_434658" labelType="html" label="ShuffledRowRDD [434658] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1088965 { id="cluster_1088965"; isCluster="true"; label="WholeStageCodegen (6)"; 434659 [id="node_434659" labelType="html" label="MapPartitionsRDD [434659] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1088942 { id="cluster_1088942"; isCluster="true"; label="WholeStageCodegen (7)"; 434660 [id="node_434660" labelType="html" label="ZippedPartitionsRDD2 [434660] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 434661 [id="node_434661" labelType="html" label="MapPartitionsRDD [434661] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1088941 { id="cluster_1088941"; isCluster="true"; label="CollectLimit"; 434662 [id="node_434662" labelType="html" label="MapPartitionsRDD [434662] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 434663 [id="node_434663" labelType="html" label="MapPartitionsRDD [434663] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } } 434649->434650; 434658->434659; 434650->434660; 434659->434660; 434660->434661; 434661->434662; 434662->434663; }
434648,434649
434657,434658
434649
434650
434660
434661
434662
434663
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