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

digraph G { subgraph clusterstage_1840 { label="Stage 1840"; 19324 [labelType="html" label="SQLExecutionRDD [19324] run at <unknown>:0"]; 19332 [labelType="html" label="SQLExecutionRDD [19332] toJavaRDD at <unknown>:0"]; 19334 [labelType="html" label="PythonRDD [19334] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster43245 { label="MicroBatchScan"; 19320 [labelType="html" label="DataSourceRDD [19320] run at <unknown>:0"]; 19321 [labelType="html" label="MapPartitionsRDD [19321] run at <unknown>:0"]; } subgraph cluster43244 { label="Project"; 19322 [labelType="html" label="MapPartitionsRDD [19322] run at <unknown>:0"]; } subgraph cluster43240 { label="WholeStageCodegen (1)"; 19323 [labelType="html" label="MapPartitionsRDD [19323] run at <unknown>:0"]; } subgraph cluster43254 { label="WholeStageCodegen (1)"; 19325 [labelType="html" label="MapPartitionsRDD [19325] toJavaRDD at <unknown>:0"]; } subgraph cluster43253 { label="Filter"; 19326 [labelType="html" label="MapPartitionsRDD [19326] toJavaRDD at <unknown>:0"]; } subgraph cluster43252 { label="Project"; 19327 [labelType="html" label="MapPartitionsRDD [19327] toJavaRDD at <unknown>:0"]; } subgraph cluster43249 { label="WholeStageCodegen (2)"; 19328 [labelType="html" label="MapPartitionsRDD [19328] toJavaRDD at <unknown>:0"]; } subgraph cluster43248 { label="Project"; 19329 [labelType="html" label="MapPartitionsRDD [19329] toJavaRDD at <unknown>:0"]; } subgraph cluster43247 { label="DeserializeToObject"; 19330 [labelType="html" label="MapPartitionsRDD [19330] toJavaRDD at <unknown>:0"]; } subgraph cluster43246 { label="MapPartitions"; 19331 [labelType="html" label="MapPartitionsRDD [19331] toJavaRDD at <unknown>:0"]; } subgraph cluster43256 { label="mapPartitions"; 19333 [labelType="html" label="MapPartitionsRDD [19333] toJavaRDD at <unknown>:0"]; } } 19320->19321; 19321->19322; 19322->19323; 19323->19324; 19324->19325; 19325->19326; 19326->19327; 19327->19328; 19328->19329; 19329->19330; 19330->19331; 19331->19332; 19332->19333; 19333->19334; }

Event Timeline

Enable zooming