processing-stream-kafka-raw-to-minio - Details for Stage 794 (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: 794

digraph G { subgraph clusterstage_794 { label="Stage 794"; 8341 [labelType="html" label="SQLExecutionRDD [8341] run at <unknown>:0"]; 8349 [labelType="html" label="SQLExecutionRDD [8349] toJavaRDD at <unknown>:0"]; 8357 [labelType="html" label="PythonRDD [8357] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster18664 { label="MicroBatchScan"; 8337 [labelType="html" label="DataSourceRDD [8337] run at <unknown>:0"]; 8338 [labelType="html" label="MapPartitionsRDD [8338] run at <unknown>:0"]; } subgraph cluster18663 { label="Project"; 8339 [labelType="html" label="MapPartitionsRDD [8339] run at <unknown>:0"]; } subgraph cluster18659 { label="WholeStageCodegen (1)"; 8340 [labelType="html" label="MapPartitionsRDD [8340] run at <unknown>:0"]; } subgraph cluster18679 { label="WholeStageCodegen (1)"; 8342 [labelType="html" label="MapPartitionsRDD [8342] toJavaRDD at <unknown>:0"]; } subgraph cluster18678 { label="Filter"; 8343 [labelType="html" label="MapPartitionsRDD [8343] toJavaRDD at <unknown>:0"]; } subgraph cluster18677 { label="Project"; 8344 [labelType="html" label="MapPartitionsRDD [8344] toJavaRDD at <unknown>:0"]; } subgraph cluster18674 { label="WholeStageCodegen (2)"; 8345 [labelType="html" label="MapPartitionsRDD [8345] toJavaRDD at <unknown>:0"]; } subgraph cluster18673 { label="Project"; 8346 [labelType="html" label="MapPartitionsRDD [8346] toJavaRDD at <unknown>:0"]; } subgraph cluster18672 { label="DeserializeToObject"; 8347 [labelType="html" label="MapPartitionsRDD [8347] toJavaRDD at <unknown>:0"]; } subgraph cluster18671 { label="MapPartitions"; 8348 [labelType="html" label="MapPartitionsRDD [8348] toJavaRDD at <unknown>:0"]; } subgraph cluster18681 { label="mapPartitions"; 8350 [labelType="html" label="MapPartitionsRDD [8350] toJavaRDD at <unknown>:0"]; } } 8337->8338; 8338->8339; 8339->8340; 8340->8341; 8341->8342; 8342->8343; 8343->8344; 8344->8345; 8345->8346; 8346->8347; 8347->8348; 8348->8349; 8349->8350; 8350->8357; }

Event Timeline

Enable zooming