4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1333539 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.2 s
Locality Level Summary:
Process local: 30
Input Size / Records:
794.0 B / 1
Shuffle Write Size / Records:
1909.0 B / 25
Associated Job Ids:
47120
DAG Visualization
digraph G { id="graph_1333539"; subgraph graph_stage_1333539 { id="graph_stage_1333539"; isCluster="true"; label="Stage 1333539"; subgraph cluster_1034857 { id="cluster_1034857"; isCluster="true"; label="repartition"; 392946 [id="node_392946" labelType="html" label="ShuffledRDD [392946] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; 392947 [id="node_392947" labelType="html" label="CoalescedRDD [392947] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; 392948 [id="node_392948" labelType="html" label="MapPartitionsRDD [392948] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035188 { id="cluster_1035188"; isCluster="true"; label="map"; 393060 [id="node_393060" labelType="html" label="MapPartitionsRDD [393060] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035191 { id="cluster_1035191"; isCluster="true"; label="WholeStageCodegen (1)"; 393061 [id="node_393061" labelType="html" label="MapPartitionsRDD [393061] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035190 { id="cluster_1035190"; isCluster="true"; label="InMemoryTableScan"; 393062 [id="node_393062" labelType="html" label="MapPartitionsRDD [393062] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; 393063 [id="node_393063" labelType="html" label="*(1) Project [shardId#5578264, item#5578272L AS worklistShardItemId#5578273L]\n+- *(1) Generate explode(_extract_worklistShardItemId#5578276), [shardId#5578264], false, [item#5578272L]\n +- *(1) Project [shardId#5578264, items#5578266.worklistShardItemId AS _extract_worklistShardItemId#5578276]\n +- *(1) Filter ((isnotnull(shardId#5578264) AND ((shardId#5578264 = 0_1_10000001445) AND (isOptimal#5578268 <=> false))) AND ((size(items#5578266.worklistShardItemId, true) > 0) AND isnotnull(items#5578266.worklistShardItemId)))\n +- *(1) Scan ExistingRDD[shardId#5578264,orderProposalId#5578265L,items#5578266,optimizationGroups#5578267,isOptimal#5578268,lastModified#5578269,optimizationInsights#5578270]\n [393063] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035233 { id="cluster_1035233"; isCluster="true"; label="InMemoryTableScan"; 393073 [id="node_393073" labelType="html" label="MapPartitionsRDD [393073] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; 393074 [id="node_393074" labelType="html" label="MapPartitionsRDD [393074] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; 393075 [id="node_393075" labelType="html" label="MapPartitionsRDD [393075] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035232 { id="cluster_1035232"; isCluster="true"; label="Exchange"; 393076 [id="node_393076" labelType="html" label="MapPartitionsRDD [393076] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } } 392946->392947; 392947->392948; 392948->393060; 393060->393061; 393061->393062; 393062->393063; 393063->393073; 393073->393074; 393074->393075; 393075->393076; }
392945,392946
392948
393063
392946
392947
392948
393060
393061
393062
393063
393073
393074
393075
393076
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