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

digraph G { subgraph clusterstage_1165 { label="Stage 1165"; 12248 [labelType="html" label="SQLExecutionRDD [12248] run at <unknown>:0"]; 12256 [labelType="html" label="SQLExecutionRDD [12256] toJavaRDD at <unknown>:0"]; 12258 [labelType="html" label="PythonRDD [12258] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster27402 { label="MicroBatchScan"; 12244 [labelType="html" label="DataSourceRDD [12244] run at <unknown>:0"]; 12245 [labelType="html" label="MapPartitionsRDD [12245] run at <unknown>:0"]; } subgraph cluster27401 { label="Project"; 12246 [labelType="html" label="MapPartitionsRDD [12246] run at <unknown>:0"]; } subgraph cluster27397 { label="WholeStageCodegen (1)"; 12247 [labelType="html" label="MapPartitionsRDD [12247] run at <unknown>:0"]; } subgraph cluster27411 { label="WholeStageCodegen (1)"; 12249 [labelType="html" label="MapPartitionsRDD [12249] toJavaRDD at <unknown>:0"]; } subgraph cluster27410 { label="Filter"; 12250 [labelType="html" label="MapPartitionsRDD [12250] toJavaRDD at <unknown>:0"]; } subgraph cluster27409 { label="Project"; 12251 [labelType="html" label="MapPartitionsRDD [12251] toJavaRDD at <unknown>:0"]; } subgraph cluster27406 { label="WholeStageCodegen (2)"; 12252 [labelType="html" label="MapPartitionsRDD [12252] toJavaRDD at <unknown>:0"]; } subgraph cluster27405 { label="Project"; 12253 [labelType="html" label="MapPartitionsRDD [12253] toJavaRDD at <unknown>:0"]; } subgraph cluster27404 { label="DeserializeToObject"; 12254 [labelType="html" label="MapPartitionsRDD [12254] toJavaRDD at <unknown>:0"]; } subgraph cluster27403 { label="MapPartitions"; 12255 [labelType="html" label="MapPartitionsRDD [12255] toJavaRDD at <unknown>:0"]; } subgraph cluster27413 { label="mapPartitions"; 12257 [labelType="html" label="MapPartitionsRDD [12257] toJavaRDD at <unknown>:0"]; } } 12244->12245; 12245->12246; 12246->12247; 12247->12248; 12248->12249; 12249->12250; 12250->12251; 12251->12252; 12252->12253; 12253->12254; 12254->12255; 12255->12256; 12256->12257; 12257->12258; }

Event Timeline

Enable zooming