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

digraph G { subgraph clusterstage_735 { label="Stage 735"; 7733 [labelType="html" label="SQLExecutionRDD [7733] run at <unknown>:0"]; 7741 [labelType="html" label="SQLExecutionRDD [7741] toJavaRDD at <unknown>:0"]; 7743 [labelType="html" label="PythonRDD [7743] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster17297 { label="MicroBatchScan"; 7729 [labelType="html" label="DataSourceRDD [7729] run at <unknown>:0"]; 7730 [labelType="html" label="MapPartitionsRDD [7730] run at <unknown>:0"]; } subgraph cluster17296 { label="Project"; 7731 [labelType="html" label="MapPartitionsRDD [7731] run at <unknown>:0"]; } subgraph cluster17292 { label="WholeStageCodegen (1)"; 7732 [labelType="html" label="MapPartitionsRDD [7732] run at <unknown>:0"]; } subgraph cluster17306 { label="WholeStageCodegen (1)"; 7734 [labelType="html" label="MapPartitionsRDD [7734] toJavaRDD at <unknown>:0"]; } subgraph cluster17305 { label="Filter"; 7735 [labelType="html" label="MapPartitionsRDD [7735] toJavaRDD at <unknown>:0"]; } subgraph cluster17304 { label="Project"; 7736 [labelType="html" label="MapPartitionsRDD [7736] toJavaRDD at <unknown>:0"]; } subgraph cluster17301 { label="WholeStageCodegen (2)"; 7737 [labelType="html" label="MapPartitionsRDD [7737] toJavaRDD at <unknown>:0"]; } subgraph cluster17300 { label="Project"; 7738 [labelType="html" label="MapPartitionsRDD [7738] toJavaRDD at <unknown>:0"]; } subgraph cluster17299 { label="DeserializeToObject"; 7739 [labelType="html" label="MapPartitionsRDD [7739] toJavaRDD at <unknown>:0"]; } subgraph cluster17298 { label="MapPartitions"; 7740 [labelType="html" label="MapPartitionsRDD [7740] toJavaRDD at <unknown>:0"]; } subgraph cluster17308 { label="mapPartitions"; 7742 [labelType="html" label="MapPartitionsRDD [7742] toJavaRDD at <unknown>:0"]; } } 7729->7730; 7730->7731; 7731->7732; 7732->7733; 7733->7734; 7734->7735; 7735->7736; 7736->7737; 7737->7738; 7738->7739; 7739->7740; 7740->7741; 7741->7742; 7742->7743; }

Event Timeline

Enable zooming