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

digraph G { subgraph clusterstage_1592 { label="Stage 1592"; 16727 [labelType="html" label="SQLExecutionRDD [16727] run at <unknown>:0"]; 16735 [labelType="html" label="SQLExecutionRDD [16735] toJavaRDD at <unknown>:0"]; 16737 [labelType="html" label="PythonRDD [16737] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster37421 { label="MicroBatchScan"; 16718 [labelType="html" label="DataSourceRDD [16718] run at <unknown>:0"]; 16721 [labelType="html" label="MapPartitionsRDD [16721] run at <unknown>:0"]; } subgraph cluster37420 { label="Project"; 16722 [labelType="html" label="MapPartitionsRDD [16722] run at <unknown>:0"]; } subgraph cluster37414 { label="WholeStageCodegen (1)"; 16726 [labelType="html" label="MapPartitionsRDD [16726] run at <unknown>:0"]; } subgraph cluster37430 { label="WholeStageCodegen (1)"; 16728 [labelType="html" label="MapPartitionsRDD [16728] toJavaRDD at <unknown>:0"]; } subgraph cluster37429 { label="Filter"; 16729 [labelType="html" label="MapPartitionsRDD [16729] toJavaRDD at <unknown>:0"]; } subgraph cluster37428 { label="Project"; 16730 [labelType="html" label="MapPartitionsRDD [16730] toJavaRDD at <unknown>:0"]; } subgraph cluster37425 { label="WholeStageCodegen (2)"; 16731 [labelType="html" label="MapPartitionsRDD [16731] toJavaRDD at <unknown>:0"]; } subgraph cluster37424 { label="Project"; 16732 [labelType="html" label="MapPartitionsRDD [16732] toJavaRDD at <unknown>:0"]; } subgraph cluster37423 { label="DeserializeToObject"; 16733 [labelType="html" label="MapPartitionsRDD [16733] toJavaRDD at <unknown>:0"]; } subgraph cluster37422 { label="MapPartitions"; 16734 [labelType="html" label="MapPartitionsRDD [16734] toJavaRDD at <unknown>:0"]; } subgraph cluster37432 { label="mapPartitions"; 16736 [labelType="html" label="MapPartitionsRDD [16736] toJavaRDD at <unknown>:0"]; } } 16718->16721; 16721->16722; 16722->16726; 16726->16727; 16727->16728; 16728->16729; 16729->16730; 16730->16731; 16731->16732; 16732->16733; 16733->16734; 16734->16735; 16735->16736; 16736->16737; }

Event Timeline

Enable zooming