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

digraph G { subgraph clusterstage_2029 { label="Stage 2029"; 21320 [labelType="html" label="SQLExecutionRDD [21320] run at <unknown>:0"]; 21328 [labelType="html" label="SQLExecutionRDD [21328] toJavaRDD at <unknown>:0"]; 21330 [labelType="html" label="PythonRDD [21330] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster47706 { label="MicroBatchScan"; 21316 [labelType="html" label="DataSourceRDD [21316] run at <unknown>:0"]; 21317 [labelType="html" label="MapPartitionsRDD [21317] run at <unknown>:0"]; } subgraph cluster47705 { label="Project"; 21318 [labelType="html" label="MapPartitionsRDD [21318] run at <unknown>:0"]; } subgraph cluster47701 { label="WholeStageCodegen (1)"; 21319 [labelType="html" label="MapPartitionsRDD [21319] run at <unknown>:0"]; } subgraph cluster47715 { label="WholeStageCodegen (1)"; 21321 [labelType="html" label="MapPartitionsRDD [21321] toJavaRDD at <unknown>:0"]; } subgraph cluster47714 { label="Filter"; 21322 [labelType="html" label="MapPartitionsRDD [21322] toJavaRDD at <unknown>:0"]; } subgraph cluster47713 { label="Project"; 21323 [labelType="html" label="MapPartitionsRDD [21323] toJavaRDD at <unknown>:0"]; } subgraph cluster47710 { label="WholeStageCodegen (2)"; 21324 [labelType="html" label="MapPartitionsRDD [21324] toJavaRDD at <unknown>:0"]; } subgraph cluster47709 { label="Project"; 21325 [labelType="html" label="MapPartitionsRDD [21325] toJavaRDD at <unknown>:0"]; } subgraph cluster47708 { label="DeserializeToObject"; 21326 [labelType="html" label="MapPartitionsRDD [21326] toJavaRDD at <unknown>:0"]; } subgraph cluster47707 { label="MapPartitions"; 21327 [labelType="html" label="MapPartitionsRDD [21327] toJavaRDD at <unknown>:0"]; } subgraph cluster47717 { label="mapPartitions"; 21329 [labelType="html" label="MapPartitionsRDD [21329] toJavaRDD at <unknown>:0"]; } } 21316->21317; 21317->21318; 21318->21319; 21319->21320; 21320->21321; 21321->21322; 21322->21323; 21323->21324; 21324->21325; 21325->21326; 21326->21327; 21327->21328; 21328->21329; 21329->21330; }

Event Timeline

Enable zooming