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

digraph G { subgraph clusterstage_1282 { label="Stage 1282"; 13465 [labelType="html" label="SQLExecutionRDD [13465] run at <unknown>:0"]; 13473 [labelType="html" label="SQLExecutionRDD [13473] toJavaRDD at <unknown>:0"]; 13475 [labelType="html" label="PythonRDD [13475] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster30132 { label="MicroBatchScan"; 13461 [labelType="html" label="DataSourceRDD [13461] run at <unknown>:0"]; 13462 [labelType="html" label="MapPartitionsRDD [13462] run at <unknown>:0"]; } subgraph cluster30131 { label="Project"; 13463 [labelType="html" label="MapPartitionsRDD [13463] run at <unknown>:0"]; } subgraph cluster30127 { label="WholeStageCodegen (1)"; 13464 [labelType="html" label="MapPartitionsRDD [13464] run at <unknown>:0"]; } subgraph cluster30141 { label="WholeStageCodegen (1)"; 13466 [labelType="html" label="MapPartitionsRDD [13466] toJavaRDD at <unknown>:0"]; } subgraph cluster30140 { label="Filter"; 13467 [labelType="html" label="MapPartitionsRDD [13467] toJavaRDD at <unknown>:0"]; } subgraph cluster30139 { label="Project"; 13468 [labelType="html" label="MapPartitionsRDD [13468] toJavaRDD at <unknown>:0"]; } subgraph cluster30136 { label="WholeStageCodegen (2)"; 13469 [labelType="html" label="MapPartitionsRDD [13469] toJavaRDD at <unknown>:0"]; } subgraph cluster30135 { label="Project"; 13470 [labelType="html" label="MapPartitionsRDD [13470] toJavaRDD at <unknown>:0"]; } subgraph cluster30134 { label="DeserializeToObject"; 13471 [labelType="html" label="MapPartitionsRDD [13471] toJavaRDD at <unknown>:0"]; } subgraph cluster30133 { label="MapPartitions"; 13472 [labelType="html" label="MapPartitionsRDD [13472] toJavaRDD at <unknown>:0"]; } subgraph cluster30143 { label="mapPartitions"; 13474 [labelType="html" label="MapPartitionsRDD [13474] toJavaRDD at <unknown>:0"]; } } 13461->13462; 13462->13463; 13463->13464; 13464->13465; 13465->13466; 13466->13467; 13467->13468; 13468->13469; 13469->13470; 13470->13471; 13471->13472; 13472->13473; 13473->13474; 13474->13475; }

Event Timeline

Enable zooming