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

digraph G { subgraph clusterstage_139 { label="Stage 139"; 1459 [labelType="html" label="SQLExecutionRDD [1459] run at <unknown>:0"]; 1467 [labelType="html" label="SQLExecutionRDD [1467] toJavaRDD at <unknown>:0"]; 1469 [labelType="html" label="PythonRDD [1469] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster3256 { label="MicroBatchScan"; 1455 [labelType="html" label="DataSourceRDD [1455] run at <unknown>:0"]; 1456 [labelType="html" label="MapPartitionsRDD [1456] run at <unknown>:0"]; } subgraph cluster3255 { label="Project"; 1457 [labelType="html" label="MapPartitionsRDD [1457] run at <unknown>:0"]; } subgraph cluster3251 { label="WholeStageCodegen (1)"; 1458 [labelType="html" label="MapPartitionsRDD [1458] run at <unknown>:0"]; } subgraph cluster3265 { label="WholeStageCodegen (1)"; 1460 [labelType="html" label="MapPartitionsRDD [1460] toJavaRDD at <unknown>:0"]; } subgraph cluster3264 { label="Filter"; 1461 [labelType="html" label="MapPartitionsRDD [1461] toJavaRDD at <unknown>:0"]; } subgraph cluster3263 { label="Project"; 1462 [labelType="html" label="MapPartitionsRDD [1462] toJavaRDD at <unknown>:0"]; } subgraph cluster3260 { label="WholeStageCodegen (2)"; 1463 [labelType="html" label="MapPartitionsRDD [1463] toJavaRDD at <unknown>:0"]; } subgraph cluster3259 { label="Project"; 1464 [labelType="html" label="MapPartitionsRDD [1464] toJavaRDD at <unknown>:0"]; } subgraph cluster3258 { label="DeserializeToObject"; 1465 [labelType="html" label="MapPartitionsRDD [1465] toJavaRDD at <unknown>:0"]; } subgraph cluster3257 { label="MapPartitions"; 1466 [labelType="html" label="MapPartitionsRDD [1466] toJavaRDD at <unknown>:0"]; } subgraph cluster3267 { label="mapPartitions"; 1468 [labelType="html" label="MapPartitionsRDD [1468] toJavaRDD at <unknown>:0"]; } } 1455->1456; 1456->1457; 1457->1458; 1458->1459; 1459->1460; 1460->1461; 1461->1462; 1462->1463; 1463->1464; 1464->1465; 1465->1466; 1466->1467; 1467->1468; 1468->1469; }

Event Timeline

Enable zooming