4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1257643 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
3 s
Locality Level Summary:
Process local: 30
Input Size / Records:
67.9 KiB / 608
Associated Job Ids:
40772
DAG Visualization
digraph G { id="graph_1257643"; subgraph graph_stage_1257643 { id="graph_stage_1257643"; isCluster="true"; label="Stage 1257643"; 331007 [id="node_331007" labelType="html" label="SQLExecutionRDD [331007] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_851139 { id="cluster_851139"; isCluster="true"; label="map"; 330860 [id="node_330860" labelType="html" label="MapPartitionsRDD [330860] [Cached] [Indeterminate]<br>map at PeriodicAsyncRDDCheckpointWriterImpl.java:207}"]; } subgraph cluster_851140 { id="cluster_851140"; isCluster="true"; label="checkpoint"; 330861 [id="node_330861" labelType="html" label="LocalCheckpointRDD [330861]<br>count at KpiCurveCacheImpl.java:242}"]; } subgraph cluster_851513 { id="cluster_851513"; isCluster="true"; label="map"; 331004 [id="node_331004" labelType="html" label="MapPartitionsRDD [331004] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_851515 { id="cluster_851515"; isCluster="true"; label="WholeStageCodegen (1)"; 331005 [id="node_331005" labelType="html" label="MapPartitionsRDD [331005] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_851514 { id="cluster_851514"; isCluster="true"; label="DeserializeToObject"; 331006 [id="node_331006" labelType="html" label="MapPartitionsRDD [331006] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_851518 { id="cluster_851518"; isCluster="true"; label="mapPartitions"; 331008 [id="node_331008" labelType="html" label="MapPartitionsRDD [331008] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_851519 { id="cluster_851519"; isCluster="true"; label="repartition"; 331009 [id="node_331009" labelType="html" label="MapPartitionsRDD [331009] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } } 330861->330860; 330860->331004; 331004->331005; 331005->331006; 331006->331007; 331007->331008; 331008->331009; }
330860
331007
330860
331004
331005
331006
331008
331009
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