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

digraph G { subgraph clusterstage_1223 { label="Stage 1223"; 12857 [labelType="html" label="SQLExecutionRDD [12857] run at <unknown>:0"]; 12865 [labelType="html" label="SQLExecutionRDD [12865] toJavaRDD at <unknown>:0"]; 12867 [labelType="html" label="PythonRDD [12867] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster28765 { label="MicroBatchScan"; 12853 [labelType="html" label="DataSourceRDD [12853] run at <unknown>:0"]; 12854 [labelType="html" label="MapPartitionsRDD [12854] run at <unknown>:0"]; } subgraph cluster28764 { label="Project"; 12855 [labelType="html" label="MapPartitionsRDD [12855] run at <unknown>:0"]; } subgraph cluster28760 { label="WholeStageCodegen (1)"; 12856 [labelType="html" label="MapPartitionsRDD [12856] run at <unknown>:0"]; } subgraph cluster28774 { label="WholeStageCodegen (1)"; 12858 [labelType="html" label="MapPartitionsRDD [12858] toJavaRDD at <unknown>:0"]; } subgraph cluster28773 { label="Filter"; 12859 [labelType="html" label="MapPartitionsRDD [12859] toJavaRDD at <unknown>:0"]; } subgraph cluster28772 { label="Project"; 12860 [labelType="html" label="MapPartitionsRDD [12860] toJavaRDD at <unknown>:0"]; } subgraph cluster28769 { label="WholeStageCodegen (2)"; 12861 [labelType="html" label="MapPartitionsRDD [12861] toJavaRDD at <unknown>:0"]; } subgraph cluster28768 { label="Project"; 12862 [labelType="html" label="MapPartitionsRDD [12862] toJavaRDD at <unknown>:0"]; } subgraph cluster28767 { label="DeserializeToObject"; 12863 [labelType="html" label="MapPartitionsRDD [12863] toJavaRDD at <unknown>:0"]; } subgraph cluster28766 { label="MapPartitions"; 12864 [labelType="html" label="MapPartitionsRDD [12864] toJavaRDD at <unknown>:0"]; } subgraph cluster28776 { label="mapPartitions"; 12866 [labelType="html" label="MapPartitionsRDD [12866] toJavaRDD at <unknown>:0"]; } } 12853->12854; 12854->12855; 12855->12856; 12856->12857; 12857->12858; 12858->12859; 12859->12860; 12860->12861; 12861->12862; 12862->12863; 12863->12864; 12864->12865; 12865->12866; 12866->12867; }

Event Timeline

Enable zooming