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

digraph G { subgraph clusterstage_1910 { label="Stage 1910"; 20059 [labelType="html" label="SQLExecutionRDD [20059] run at <unknown>:0"]; 20067 [labelType="html" label="SQLExecutionRDD [20067] toJavaRDD at <unknown>:0"]; 20069 [labelType="html" label="PythonRDD [20069] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster44890 { label="MicroBatchScan"; 20055 [labelType="html" label="DataSourceRDD [20055] run at <unknown>:0"]; 20056 [labelType="html" label="MapPartitionsRDD [20056] run at <unknown>:0"]; } subgraph cluster44889 { label="Project"; 20057 [labelType="html" label="MapPartitionsRDD [20057] run at <unknown>:0"]; } subgraph cluster44885 { label="WholeStageCodegen (1)"; 20058 [labelType="html" label="MapPartitionsRDD [20058] run at <unknown>:0"]; } subgraph cluster44899 { label="WholeStageCodegen (1)"; 20060 [labelType="html" label="MapPartitionsRDD [20060] toJavaRDD at <unknown>:0"]; } subgraph cluster44898 { label="Filter"; 20061 [labelType="html" label="MapPartitionsRDD [20061] toJavaRDD at <unknown>:0"]; } subgraph cluster44897 { label="Project"; 20062 [labelType="html" label="MapPartitionsRDD [20062] toJavaRDD at <unknown>:0"]; } subgraph cluster44894 { label="WholeStageCodegen (2)"; 20063 [labelType="html" label="MapPartitionsRDD [20063] toJavaRDD at <unknown>:0"]; } subgraph cluster44893 { label="Project"; 20064 [labelType="html" label="MapPartitionsRDD [20064] toJavaRDD at <unknown>:0"]; } subgraph cluster44892 { label="DeserializeToObject"; 20065 [labelType="html" label="MapPartitionsRDD [20065] toJavaRDD at <unknown>:0"]; } subgraph cluster44891 { label="MapPartitions"; 20066 [labelType="html" label="MapPartitionsRDD [20066] toJavaRDD at <unknown>:0"]; } subgraph cluster44901 { label="mapPartitions"; 20068 [labelType="html" label="MapPartitionsRDD [20068] toJavaRDD at <unknown>:0"]; } } 20055->20056; 20056->20057; 20057->20058; 20058->20059; 20059->20060; 20060->20061; 20061->20062; 20062->20063; 20063->20064; 20064->20065; 20065->20066; 20066->20067; 20067->20068; 20068->20069; }

Event Timeline

Enable zooming