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

digraph G { subgraph clusterstage_1224 { label="Stage 1224"; 12863 [labelType="html" label="SQLExecutionRDD [12863] run at <unknown>:0"]; 12871 [labelType="html" label="SQLExecutionRDD [12871] toJavaRDD at <unknown>:0"]; 12873 [labelType="html" label="PythonRDD [12873] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster28773 { label="MicroBatchScan"; 12859 [labelType="html" label="DataSourceRDD [12859] run at <unknown>:0"]; 12860 [labelType="html" label="MapPartitionsRDD [12860] run at <unknown>:0"]; } subgraph cluster28772 { label="Project"; 12861 [labelType="html" label="MapPartitionsRDD [12861] run at <unknown>:0"]; } subgraph cluster28768 { label="WholeStageCodegen (1)"; 12862 [labelType="html" label="MapPartitionsRDD [12862] run at <unknown>:0"]; } subgraph cluster28782 { label="WholeStageCodegen (1)"; 12864 [labelType="html" label="MapPartitionsRDD [12864] toJavaRDD at <unknown>:0"]; } subgraph cluster28781 { label="Filter"; 12865 [labelType="html" label="MapPartitionsRDD [12865] toJavaRDD at <unknown>:0"]; } subgraph cluster28780 { label="Project"; 12866 [labelType="html" label="MapPartitionsRDD [12866] toJavaRDD at <unknown>:0"]; } subgraph cluster28777 { label="WholeStageCodegen (2)"; 12867 [labelType="html" label="MapPartitionsRDD [12867] toJavaRDD at <unknown>:0"]; } subgraph cluster28776 { label="Project"; 12868 [labelType="html" label="MapPartitionsRDD [12868] toJavaRDD at <unknown>:0"]; } subgraph cluster28775 { label="DeserializeToObject"; 12869 [labelType="html" label="MapPartitionsRDD [12869] toJavaRDD at <unknown>:0"]; } subgraph cluster28774 { label="MapPartitions"; 12870 [labelType="html" label="MapPartitionsRDD [12870] toJavaRDD at <unknown>:0"]; } subgraph cluster28784 { label="mapPartitions"; 12872 [labelType="html" label="MapPartitionsRDD [12872] toJavaRDD at <unknown>:0"]; } } 12859->12860; 12860->12861; 12861->12862; 12862->12863; 12863->12864; 12864->12865; 12865->12866; 12866->12867; 12867->12868; 12868->12869; 12869->12870; 12870->12871; 12871->12872; 12872->12873; }

Event Timeline

Enable zooming