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

digraph G { subgraph clusterstage_1546 { label="Stage 1546"; 16237 [labelType="html" label="SQLExecutionRDD [16237] run at <unknown>:0"]; 16245 [labelType="html" label="SQLExecutionRDD [16245] toJavaRDD at <unknown>:0"]; 16247 [labelType="html" label="PythonRDD [16247] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster36336 { label="MicroBatchScan"; 16233 [labelType="html" label="DataSourceRDD [16233] run at <unknown>:0"]; 16234 [labelType="html" label="MapPartitionsRDD [16234] run at <unknown>:0"]; } subgraph cluster36335 { label="Project"; 16235 [labelType="html" label="MapPartitionsRDD [16235] run at <unknown>:0"]; } subgraph cluster36331 { label="WholeStageCodegen (1)"; 16236 [labelType="html" label="MapPartitionsRDD [16236] run at <unknown>:0"]; } subgraph cluster36345 { label="WholeStageCodegen (1)"; 16238 [labelType="html" label="MapPartitionsRDD [16238] toJavaRDD at <unknown>:0"]; } subgraph cluster36344 { label="Filter"; 16239 [labelType="html" label="MapPartitionsRDD [16239] toJavaRDD at <unknown>:0"]; } subgraph cluster36343 { label="Project"; 16240 [labelType="html" label="MapPartitionsRDD [16240] toJavaRDD at <unknown>:0"]; } subgraph cluster36340 { label="WholeStageCodegen (2)"; 16241 [labelType="html" label="MapPartitionsRDD [16241] toJavaRDD at <unknown>:0"]; } subgraph cluster36339 { label="Project"; 16242 [labelType="html" label="MapPartitionsRDD [16242] toJavaRDD at <unknown>:0"]; } subgraph cluster36338 { label="DeserializeToObject"; 16243 [labelType="html" label="MapPartitionsRDD [16243] toJavaRDD at <unknown>:0"]; } subgraph cluster36337 { label="MapPartitions"; 16244 [labelType="html" label="MapPartitionsRDD [16244] toJavaRDD at <unknown>:0"]; } subgraph cluster36347 { label="mapPartitions"; 16246 [labelType="html" label="MapPartitionsRDD [16246] toJavaRDD at <unknown>:0"]; } } 16233->16234; 16234->16235; 16235->16236; 16236->16237; 16237->16238; 16238->16239; 16239->16240; 16240->16241; 16241->16242; 16242->16243; 16243->16244; 16244->16245; 16245->16246; 16246->16247; }

Event Timeline

Enable zooming