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

digraph G { subgraph clusterstage_1635 { label="Stage 1635"; 17183 [labelType="html" label="SQLExecutionRDD [17183] run at <unknown>:0"]; 17191 [labelType="html" label="SQLExecutionRDD [17191] toJavaRDD at <unknown>:0"]; 17193 [labelType="html" label="PythonRDD [17193] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster38447 { label="MicroBatchScan"; 17179 [labelType="html" label="DataSourceRDD [17179] run at <unknown>:0"]; 17180 [labelType="html" label="MapPartitionsRDD [17180] run at <unknown>:0"]; } subgraph cluster38446 { label="Project"; 17181 [labelType="html" label="MapPartitionsRDD [17181] run at <unknown>:0"]; } subgraph cluster38442 { label="WholeStageCodegen (1)"; 17182 [labelType="html" label="MapPartitionsRDD [17182] run at <unknown>:0"]; } subgraph cluster38456 { label="WholeStageCodegen (1)"; 17184 [labelType="html" label="MapPartitionsRDD [17184] toJavaRDD at <unknown>:0"]; } subgraph cluster38455 { label="Filter"; 17185 [labelType="html" label="MapPartitionsRDD [17185] toJavaRDD at <unknown>:0"]; } subgraph cluster38454 { label="Project"; 17186 [labelType="html" label="MapPartitionsRDD [17186] toJavaRDD at <unknown>:0"]; } subgraph cluster38451 { label="WholeStageCodegen (2)"; 17187 [labelType="html" label="MapPartitionsRDD [17187] toJavaRDD at <unknown>:0"]; } subgraph cluster38450 { label="Project"; 17188 [labelType="html" label="MapPartitionsRDD [17188] toJavaRDD at <unknown>:0"]; } subgraph cluster38449 { label="DeserializeToObject"; 17189 [labelType="html" label="MapPartitionsRDD [17189] toJavaRDD at <unknown>:0"]; } subgraph cluster38448 { label="MapPartitions"; 17190 [labelType="html" label="MapPartitionsRDD [17190] toJavaRDD at <unknown>:0"]; } subgraph cluster38458 { label="mapPartitions"; 17192 [labelType="html" label="MapPartitionsRDD [17192] toJavaRDD at <unknown>:0"]; } } 17179->17180; 17180->17181; 17181->17182; 17182->17183; 17183->17184; 17184->17185; 17185->17186; 17186->17187; 17187->17188; 17188->17189; 17189->17190; 17190->17191; 17191->17192; 17192->17193; }

Event Timeline

Enable zooming