processing-stream-kafka-raw-to-minio - Details for Stage 1928 (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 / 512
Associated Job Ids: 1928

digraph G { subgraph clusterstage_1928 { label="Stage 1928"; 20248 [labelType="html" label="SQLExecutionRDD [20248] run at <unknown>:0"]; 20256 [labelType="html" label="SQLExecutionRDD [20256] toJavaRDD at <unknown>:0"]; 20258 [labelType="html" label="PythonRDD [20258] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster45313 { label="MicroBatchScan"; 20244 [labelType="html" label="DataSourceRDD [20244] run at <unknown>:0"]; 20245 [labelType="html" label="MapPartitionsRDD [20245] run at <unknown>:0"]; } subgraph cluster45312 { label="Project"; 20246 [labelType="html" label="MapPartitionsRDD [20246] run at <unknown>:0"]; } subgraph cluster45308 { label="WholeStageCodegen (1)"; 20247 [labelType="html" label="MapPartitionsRDD [20247] run at <unknown>:0"]; } subgraph cluster45322 { label="WholeStageCodegen (1)"; 20249 [labelType="html" label="MapPartitionsRDD [20249] toJavaRDD at <unknown>:0"]; } subgraph cluster45321 { label="Filter"; 20250 [labelType="html" label="MapPartitionsRDD [20250] toJavaRDD at <unknown>:0"]; } subgraph cluster45320 { label="Project"; 20251 [labelType="html" label="MapPartitionsRDD [20251] toJavaRDD at <unknown>:0"]; } subgraph cluster45317 { label="WholeStageCodegen (2)"; 20252 [labelType="html" label="MapPartitionsRDD [20252] toJavaRDD at <unknown>:0"]; } subgraph cluster45316 { label="Project"; 20253 [labelType="html" label="MapPartitionsRDD [20253] toJavaRDD at <unknown>:0"]; } subgraph cluster45315 { label="DeserializeToObject"; 20254 [labelType="html" label="MapPartitionsRDD [20254] toJavaRDD at <unknown>:0"]; } subgraph cluster45314 { label="MapPartitions"; 20255 [labelType="html" label="MapPartitionsRDD [20255] toJavaRDD at <unknown>:0"]; } subgraph cluster45324 { label="mapPartitions"; 20257 [labelType="html" label="MapPartitionsRDD [20257] toJavaRDD at <unknown>:0"]; } } 20244->20245; 20245->20246; 20246->20247; 20247->20248; 20248->20249; 20249->20250; 20250->20251; 20251->20252; 20252->20253; 20253->20254; 20254->20255; 20255->20256; 20256->20257; 20257->20258; }

Event Timeline

Enable zooming