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

digraph G { subgraph clusterstage_1261 { label="Stage 1261"; 13240 [labelType="html" label="SQLExecutionRDD [13240] run at <unknown>:0"]; 13248 [labelType="html" label="SQLExecutionRDD [13248] toJavaRDD at <unknown>:0"]; 13250 [labelType="html" label="PythonRDD [13250] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster29623 { label="MicroBatchScan"; 13236 [labelType="html" label="DataSourceRDD [13236] run at <unknown>:0"]; 13237 [labelType="html" label="MapPartitionsRDD [13237] run at <unknown>:0"]; } subgraph cluster29622 { label="Project"; 13238 [labelType="html" label="MapPartitionsRDD [13238] run at <unknown>:0"]; } subgraph cluster29616 { label="WholeStageCodegen (1)"; 13239 [labelType="html" label="MapPartitionsRDD [13239] run at <unknown>:0"]; } subgraph cluster29632 { label="WholeStageCodegen (1)"; 13241 [labelType="html" label="MapPartitionsRDD [13241] toJavaRDD at <unknown>:0"]; } subgraph cluster29631 { label="Filter"; 13242 [labelType="html" label="MapPartitionsRDD [13242] toJavaRDD at <unknown>:0"]; } subgraph cluster29630 { label="Project"; 13243 [labelType="html" label="MapPartitionsRDD [13243] toJavaRDD at <unknown>:0"]; } subgraph cluster29627 { label="WholeStageCodegen (2)"; 13244 [labelType="html" label="MapPartitionsRDD [13244] toJavaRDD at <unknown>:0"]; } subgraph cluster29626 { label="Project"; 13245 [labelType="html" label="MapPartitionsRDD [13245] toJavaRDD at <unknown>:0"]; } subgraph cluster29625 { label="DeserializeToObject"; 13246 [labelType="html" label="MapPartitionsRDD [13246] toJavaRDD at <unknown>:0"]; } subgraph cluster29624 { label="MapPartitions"; 13247 [labelType="html" label="MapPartitionsRDD [13247] toJavaRDD at <unknown>:0"]; } subgraph cluster29634 { label="mapPartitions"; 13249 [labelType="html" label="MapPartitionsRDD [13249] toJavaRDD at <unknown>:0"]; } } 13236->13237; 13237->13238; 13238->13239; 13239->13240; 13240->13241; 13241->13242; 13242->13243; 13243->13244; 13244->13245; 13245->13246; 13246->13247; 13247->13248; 13248->13249; 13249->13250; }

Event Timeline

Enable zooming