processing-stream-kafka-raw-to-minio - Details for Stage 1069 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 3
Input Size / Records: 0.0 B / 498
Associated Job Ids: 1070

digraph G { subgraph clusterstage_1069 { label="Stage 1069"; 11240 [labelType="html" label="SQLExecutionRDD [11240] run at <unknown>:0"]; 11248 [labelType="html" label="SQLExecutionRDD [11248] toJavaRDD at <unknown>:0"]; 11250 [labelType="html" label="PythonRDD [11250] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster25146 { label="MicroBatchScan"; 11236 [labelType="html" label="DataSourceRDD [11236] run at <unknown>:0"]; 11237 [labelType="html" label="MapPartitionsRDD [11237] run at <unknown>:0"]; } subgraph cluster25145 { label="Project"; 11238 [labelType="html" label="MapPartitionsRDD [11238] run at <unknown>:0"]; } subgraph cluster25141 { label="WholeStageCodegen (1)"; 11239 [labelType="html" label="MapPartitionsRDD [11239] run at <unknown>:0"]; } subgraph cluster25155 { label="WholeStageCodegen (1)"; 11241 [labelType="html" label="MapPartitionsRDD [11241] toJavaRDD at <unknown>:0"]; } subgraph cluster25154 { label="Filter"; 11242 [labelType="html" label="MapPartitionsRDD [11242] toJavaRDD at <unknown>:0"]; } subgraph cluster25153 { label="Project"; 11243 [labelType="html" label="MapPartitionsRDD [11243] toJavaRDD at <unknown>:0"]; } subgraph cluster25150 { label="WholeStageCodegen (2)"; 11244 [labelType="html" label="MapPartitionsRDD [11244] toJavaRDD at <unknown>:0"]; } subgraph cluster25149 { label="Project"; 11245 [labelType="html" label="MapPartitionsRDD [11245] toJavaRDD at <unknown>:0"]; } subgraph cluster25148 { label="DeserializeToObject"; 11246 [labelType="html" label="MapPartitionsRDD [11246] toJavaRDD at <unknown>:0"]; } subgraph cluster25147 { label="MapPartitions"; 11247 [labelType="html" label="MapPartitionsRDD [11247] toJavaRDD at <unknown>:0"]; } subgraph cluster25157 { label="mapPartitions"; 11249 [labelType="html" label="MapPartitionsRDD [11249] toJavaRDD at <unknown>:0"]; } } 11236->11237; 11237->11238; 11238->11239; 11239->11240; 11240->11241; 11241->11242; 11242->11243; 11243->11244; 11244->11245; 11245->11246; 11246->11247; 11247->11248; 11248->11249; 11249->11250; }

Event Timeline

Enable zooming