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

digraph G { subgraph clusterstage_995 { label="Stage 995"; 10463 [labelType="html" label="SQLExecutionRDD [10463] run at <unknown>:0"]; 10471 [labelType="html" label="SQLExecutionRDD [10471] toJavaRDD at <unknown>:0"]; 10473 [labelType="html" label="PythonRDD [10473] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster23407 { label="MicroBatchScan"; 10459 [labelType="html" label="DataSourceRDD [10459] run at <unknown>:0"]; 10460 [labelType="html" label="MapPartitionsRDD [10460] run at <unknown>:0"]; } subgraph cluster23406 { label="Project"; 10461 [labelType="html" label="MapPartitionsRDD [10461] run at <unknown>:0"]; } subgraph cluster23402 { label="WholeStageCodegen (1)"; 10462 [labelType="html" label="MapPartitionsRDD [10462] run at <unknown>:0"]; } subgraph cluster23416 { label="WholeStageCodegen (1)"; 10464 [labelType="html" label="MapPartitionsRDD [10464] toJavaRDD at <unknown>:0"]; } subgraph cluster23415 { label="Filter"; 10465 [labelType="html" label="MapPartitionsRDD [10465] toJavaRDD at <unknown>:0"]; } subgraph cluster23414 { label="Project"; 10466 [labelType="html" label="MapPartitionsRDD [10466] toJavaRDD at <unknown>:0"]; } subgraph cluster23411 { label="WholeStageCodegen (2)"; 10467 [labelType="html" label="MapPartitionsRDD [10467] toJavaRDD at <unknown>:0"]; } subgraph cluster23410 { label="Project"; 10468 [labelType="html" label="MapPartitionsRDD [10468] toJavaRDD at <unknown>:0"]; } subgraph cluster23409 { label="DeserializeToObject"; 10469 [labelType="html" label="MapPartitionsRDD [10469] toJavaRDD at <unknown>:0"]; } subgraph cluster23408 { label="MapPartitions"; 10470 [labelType="html" label="MapPartitionsRDD [10470] toJavaRDD at <unknown>:0"]; } subgraph cluster23418 { label="mapPartitions"; 10472 [labelType="html" label="MapPartitionsRDD [10472] toJavaRDD at <unknown>:0"]; } } 10459->10460; 10460->10461; 10461->10462; 10462->10463; 10463->10464; 10464->10465; 10465->10466; 10466->10467; 10467->10468; 10468->10469; 10469->10470; 10470->10471; 10471->10472; 10472->10473; }

Event Timeline

Enable zooming