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

digraph G { subgraph clusterstage_1357 { label="Stage 1357"; 14242 [labelType="html" label="SQLExecutionRDD [14242] run at <unknown>:0"]; 14256 [labelType="html" label="SQLExecutionRDD [14256] toJavaRDD at <unknown>:0"]; 14258 [labelType="html" label="PythonRDD [14258] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster31871 { label="MicroBatchScan"; 14238 [labelType="html" label="DataSourceRDD [14238] run at <unknown>:0"]; 14239 [labelType="html" label="MapPartitionsRDD [14239] run at <unknown>:0"]; } subgraph cluster31870 { label="Project"; 14240 [labelType="html" label="MapPartitionsRDD [14240] run at <unknown>:0"]; } subgraph cluster31866 { label="WholeStageCodegen (1)"; 14241 [labelType="html" label="MapPartitionsRDD [14241] run at <unknown>:0"]; } subgraph cluster31888 { label="WholeStageCodegen (1)"; 14249 [labelType="html" label="MapPartitionsRDD [14249] toJavaRDD at <unknown>:0"]; } subgraph cluster31887 { label="Filter"; 14250 [labelType="html" label="MapPartitionsRDD [14250] toJavaRDD at <unknown>:0"]; } subgraph cluster31886 { label="Project"; 14251 [labelType="html" label="MapPartitionsRDD [14251] toJavaRDD at <unknown>:0"]; } subgraph cluster31883 { label="WholeStageCodegen (2)"; 14252 [labelType="html" label="MapPartitionsRDD [14252] toJavaRDD at <unknown>:0"]; } subgraph cluster31882 { label="Project"; 14253 [labelType="html" label="MapPartitionsRDD [14253] toJavaRDD at <unknown>:0"]; } subgraph cluster31881 { label="DeserializeToObject"; 14254 [labelType="html" label="MapPartitionsRDD [14254] toJavaRDD at <unknown>:0"]; } subgraph cluster31880 { label="MapPartitions"; 14255 [labelType="html" label="MapPartitionsRDD [14255] toJavaRDD at <unknown>:0"]; } subgraph cluster31890 { label="mapPartitions"; 14257 [labelType="html" label="MapPartitionsRDD [14257] toJavaRDD at <unknown>:0"]; } } 14238->14239; 14239->14240; 14240->14241; 14241->14242; 14242->14249; 14249->14250; 14250->14251; 14251->14252; 14252->14253; 14253->14254; 14254->14255; 14255->14256; 14256->14257; 14257->14258; }

Event Timeline

Enable zooming