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

digraph G { subgraph clusterstage_1824 { label="Stage 1824"; 19156 [labelType="html" label="SQLExecutionRDD [19156] run at <unknown>:0"]; 19164 [labelType="html" label="SQLExecutionRDD [19164] toJavaRDD at <unknown>:0"]; 19166 [labelType="html" label="PythonRDD [19166] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster42869 { label="MicroBatchScan"; 19152 [labelType="html" label="DataSourceRDD [19152] run at <unknown>:0"]; 19153 [labelType="html" label="MapPartitionsRDD [19153] run at <unknown>:0"]; } subgraph cluster42868 { label="Project"; 19154 [labelType="html" label="MapPartitionsRDD [19154] run at <unknown>:0"]; } subgraph cluster42864 { label="WholeStageCodegen (1)"; 19155 [labelType="html" label="MapPartitionsRDD [19155] run at <unknown>:0"]; } subgraph cluster42878 { label="WholeStageCodegen (1)"; 19157 [labelType="html" label="MapPartitionsRDD [19157] toJavaRDD at <unknown>:0"]; } subgraph cluster42877 { label="Filter"; 19158 [labelType="html" label="MapPartitionsRDD [19158] toJavaRDD at <unknown>:0"]; } subgraph cluster42876 { label="Project"; 19159 [labelType="html" label="MapPartitionsRDD [19159] toJavaRDD at <unknown>:0"]; } subgraph cluster42873 { label="WholeStageCodegen (2)"; 19160 [labelType="html" label="MapPartitionsRDD [19160] toJavaRDD at <unknown>:0"]; } subgraph cluster42872 { label="Project"; 19161 [labelType="html" label="MapPartitionsRDD [19161] toJavaRDD at <unknown>:0"]; } subgraph cluster42871 { label="DeserializeToObject"; 19162 [labelType="html" label="MapPartitionsRDD [19162] toJavaRDD at <unknown>:0"]; } subgraph cluster42870 { label="MapPartitions"; 19163 [labelType="html" label="MapPartitionsRDD [19163] toJavaRDD at <unknown>:0"]; } subgraph cluster42880 { label="mapPartitions"; 19165 [labelType="html" label="MapPartitionsRDD [19165] toJavaRDD at <unknown>:0"]; } } 19152->19153; 19153->19154; 19154->19155; 19155->19156; 19156->19157; 19157->19158; 19158->19159; 19159->19160; 19160->19161; 19161->19162; 19162->19163; 19163->19164; 19164->19165; 19165->19166; }

Event Timeline

Enable zooming