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

digraph G { subgraph clusterstage_1448 { label="Stage 1448"; 15215 [labelType="html" label="SQLExecutionRDD [15215] run at <unknown>:0"]; 15223 [labelType="html" label="SQLExecutionRDD [15223] toJavaRDD at <unknown>:0"]; 15225 [labelType="html" label="PythonRDD [15225] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster34037 { label="MicroBatchScan"; 15211 [labelType="html" label="DataSourceRDD [15211] run at <unknown>:0"]; 15212 [labelType="html" label="MapPartitionsRDD [15212] run at <unknown>:0"]; } subgraph cluster34036 { label="Project"; 15213 [labelType="html" label="MapPartitionsRDD [15213] run at <unknown>:0"]; } subgraph cluster34032 { label="WholeStageCodegen (1)"; 15214 [labelType="html" label="MapPartitionsRDD [15214] run at <unknown>:0"]; } subgraph cluster34046 { label="WholeStageCodegen (1)"; 15216 [labelType="html" label="MapPartitionsRDD [15216] toJavaRDD at <unknown>:0"]; } subgraph cluster34045 { label="Filter"; 15217 [labelType="html" label="MapPartitionsRDD [15217] toJavaRDD at <unknown>:0"]; } subgraph cluster34044 { label="Project"; 15218 [labelType="html" label="MapPartitionsRDD [15218] toJavaRDD at <unknown>:0"]; } subgraph cluster34041 { label="WholeStageCodegen (2)"; 15219 [labelType="html" label="MapPartitionsRDD [15219] toJavaRDD at <unknown>:0"]; } subgraph cluster34040 { label="Project"; 15220 [labelType="html" label="MapPartitionsRDD [15220] toJavaRDD at <unknown>:0"]; } subgraph cluster34039 { label="DeserializeToObject"; 15221 [labelType="html" label="MapPartitionsRDD [15221] toJavaRDD at <unknown>:0"]; } subgraph cluster34038 { label="MapPartitions"; 15222 [labelType="html" label="MapPartitionsRDD [15222] toJavaRDD at <unknown>:0"]; } subgraph cluster34048 { label="mapPartitions"; 15224 [labelType="html" label="MapPartitionsRDD [15224] toJavaRDD at <unknown>:0"]; } } 15211->15212; 15212->15213; 15213->15214; 15214->15215; 15215->15216; 15216->15217; 15217->15218; 15218->15219; 15219->15220; 15220->15221; 15221->15222; 15222->15223; 15223->15224; 15224->15225; }

Event Timeline

Enable zooming