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

digraph G { subgraph clusterstage_1227 { label="Stage 1227"; 12899 [labelType="html" label="SQLExecutionRDD [12899] run at <unknown>:0"]; 12907 [labelType="html" label="SQLExecutionRDD [12907] toJavaRDD at <unknown>:0"]; 12909 [labelType="html" label="PythonRDD [12909] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster28859 { label="MicroBatchScan"; 12895 [labelType="html" label="DataSourceRDD [12895] run at <unknown>:0"]; 12896 [labelType="html" label="MapPartitionsRDD [12896] run at <unknown>:0"]; } subgraph cluster28858 { label="Project"; 12897 [labelType="html" label="MapPartitionsRDD [12897] run at <unknown>:0"]; } subgraph cluster28854 { label="WholeStageCodegen (1)"; 12898 [labelType="html" label="MapPartitionsRDD [12898] run at <unknown>:0"]; } subgraph cluster28868 { label="WholeStageCodegen (1)"; 12900 [labelType="html" label="MapPartitionsRDD [12900] toJavaRDD at <unknown>:0"]; } subgraph cluster28867 { label="Filter"; 12901 [labelType="html" label="MapPartitionsRDD [12901] toJavaRDD at <unknown>:0"]; } subgraph cluster28866 { label="Project"; 12902 [labelType="html" label="MapPartitionsRDD [12902] toJavaRDD at <unknown>:0"]; } subgraph cluster28863 { label="WholeStageCodegen (2)"; 12903 [labelType="html" label="MapPartitionsRDD [12903] toJavaRDD at <unknown>:0"]; } subgraph cluster28862 { label="Project"; 12904 [labelType="html" label="MapPartitionsRDD [12904] toJavaRDD at <unknown>:0"]; } subgraph cluster28861 { label="DeserializeToObject"; 12905 [labelType="html" label="MapPartitionsRDD [12905] toJavaRDD at <unknown>:0"]; } subgraph cluster28860 { label="MapPartitions"; 12906 [labelType="html" label="MapPartitionsRDD [12906] toJavaRDD at <unknown>:0"]; } subgraph cluster28870 { label="mapPartitions"; 12908 [labelType="html" label="MapPartitionsRDD [12908] toJavaRDD at <unknown>:0"]; } } 12895->12896; 12896->12897; 12897->12898; 12898->12899; 12899->12900; 12900->12901; 12901->12902; 12902->12903; 12903->12904; 12904->12905; 12905->12906; 12906->12907; 12907->12908; 12908->12909; }

Event Timeline

Enable zooming