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

digraph G { subgraph clusterstage_1499 { label="Stage 1499"; 15733 [labelType="html" label="SQLExecutionRDD [15733] run at <unknown>:0"]; 15747 [labelType="html" label="SQLExecutionRDD [15747] toJavaRDD at <unknown>:0"]; 15749 [labelType="html" label="PythonRDD [15749] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster35208 { label="MicroBatchScan"; 15729 [labelType="html" label="DataSourceRDD [15729] run at <unknown>:0"]; 15730 [labelType="html" label="MapPartitionsRDD [15730] run at <unknown>:0"]; } subgraph cluster35207 { label="Project"; 15731 [labelType="html" label="MapPartitionsRDD [15731] run at <unknown>:0"]; } subgraph cluster35203 { label="WholeStageCodegen (1)"; 15732 [labelType="html" label="MapPartitionsRDD [15732] run at <unknown>:0"]; } subgraph cluster35225 { label="WholeStageCodegen (1)"; 15740 [labelType="html" label="MapPartitionsRDD [15740] toJavaRDD at <unknown>:0"]; } subgraph cluster35224 { label="Filter"; 15741 [labelType="html" label="MapPartitionsRDD [15741] toJavaRDD at <unknown>:0"]; } subgraph cluster35223 { label="Project"; 15742 [labelType="html" label="MapPartitionsRDD [15742] toJavaRDD at <unknown>:0"]; } subgraph cluster35220 { label="WholeStageCodegen (2)"; 15743 [labelType="html" label="MapPartitionsRDD [15743] toJavaRDD at <unknown>:0"]; } subgraph cluster35219 { label="Project"; 15744 [labelType="html" label="MapPartitionsRDD [15744] toJavaRDD at <unknown>:0"]; } subgraph cluster35218 { label="DeserializeToObject"; 15745 [labelType="html" label="MapPartitionsRDD [15745] toJavaRDD at <unknown>:0"]; } subgraph cluster35217 { label="MapPartitions"; 15746 [labelType="html" label="MapPartitionsRDD [15746] toJavaRDD at <unknown>:0"]; } subgraph cluster35227 { label="mapPartitions"; 15748 [labelType="html" label="MapPartitionsRDD [15748] toJavaRDD at <unknown>:0"]; } } 15729->15730; 15730->15731; 15731->15732; 15732->15733; 15733->15740; 15740->15741; 15741->15742; 15742->15743; 15743->15744; 15744->15745; 15745->15746; 15746->15747; 15747->15748; 15748->15749; }

Event Timeline

Enable zooming