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

digraph G { subgraph clusterstage_1989 { label="Stage 1989"; 20900 [labelType="html" label="SQLExecutionRDD [20900] run at <unknown>:0"]; 20908 [labelType="html" label="SQLExecutionRDD [20908] toJavaRDD at <unknown>:0"]; 20910 [labelType="html" label="PythonRDD [20910] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster46766 { label="MicroBatchScan"; 20896 [labelType="html" label="DataSourceRDD [20896] run at <unknown>:0"]; 20897 [labelType="html" label="MapPartitionsRDD [20897] run at <unknown>:0"]; } subgraph cluster46765 { label="Project"; 20898 [labelType="html" label="MapPartitionsRDD [20898] run at <unknown>:0"]; } subgraph cluster46761 { label="WholeStageCodegen (1)"; 20899 [labelType="html" label="MapPartitionsRDD [20899] run at <unknown>:0"]; } subgraph cluster46775 { label="WholeStageCodegen (1)"; 20901 [labelType="html" label="MapPartitionsRDD [20901] toJavaRDD at <unknown>:0"]; } subgraph cluster46774 { label="Filter"; 20902 [labelType="html" label="MapPartitionsRDD [20902] toJavaRDD at <unknown>:0"]; } subgraph cluster46773 { label="Project"; 20903 [labelType="html" label="MapPartitionsRDD [20903] toJavaRDD at <unknown>:0"]; } subgraph cluster46770 { label="WholeStageCodegen (2)"; 20904 [labelType="html" label="MapPartitionsRDD [20904] toJavaRDD at <unknown>:0"]; } subgraph cluster46769 { label="Project"; 20905 [labelType="html" label="MapPartitionsRDD [20905] toJavaRDD at <unknown>:0"]; } subgraph cluster46768 { label="DeserializeToObject"; 20906 [labelType="html" label="MapPartitionsRDD [20906] toJavaRDD at <unknown>:0"]; } subgraph cluster46767 { label="MapPartitions"; 20907 [labelType="html" label="MapPartitionsRDD [20907] toJavaRDD at <unknown>:0"]; } subgraph cluster46777 { label="mapPartitions"; 20909 [labelType="html" label="MapPartitionsRDD [20909] toJavaRDD at <unknown>:0"]; } } 20896->20897; 20897->20898; 20898->20899; 20899->20900; 20900->20901; 20901->20902; 20902->20903; 20903->20904; 20904->20905; 20905->20906; 20906->20907; 20907->20908; 20908->20909; 20909->20910; }

Event Timeline

Enable zooming