processing-stream-kafka-raw-to-minio - Details for Stage 234 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 4
Input Size / Records: 0.0 B / 358
Associated Job Ids: 234

digraph G { subgraph clusterstage_234 { label="Stage 234"; 2461 [labelType="html" label="SQLExecutionRDD [2461] run at <unknown>:0"]; 2469 [labelType="html" label="SQLExecutionRDD [2469] toJavaRDD at <unknown>:0"]; 2471 [labelType="html" label="PythonRDD [2471] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster5504 { label="MicroBatchScan"; 2457 [labelType="html" label="DataSourceRDD [2457] run at <unknown>:0"]; 2458 [labelType="html" label="MapPartitionsRDD [2458] run at <unknown>:0"]; } subgraph cluster5503 { label="Project"; 2459 [labelType="html" label="MapPartitionsRDD [2459] run at <unknown>:0"]; } subgraph cluster5499 { label="WholeStageCodegen (1)"; 2460 [labelType="html" label="MapPartitionsRDD [2460] run at <unknown>:0"]; } subgraph cluster5513 { label="WholeStageCodegen (1)"; 2462 [labelType="html" label="MapPartitionsRDD [2462] toJavaRDD at <unknown>:0"]; } subgraph cluster5512 { label="Filter"; 2463 [labelType="html" label="MapPartitionsRDD [2463] toJavaRDD at <unknown>:0"]; } subgraph cluster5511 { label="Project"; 2464 [labelType="html" label="MapPartitionsRDD [2464] toJavaRDD at <unknown>:0"]; } subgraph cluster5508 { label="WholeStageCodegen (2)"; 2465 [labelType="html" label="MapPartitionsRDD [2465] toJavaRDD at <unknown>:0"]; } subgraph cluster5507 { label="Project"; 2466 [labelType="html" label="MapPartitionsRDD [2466] toJavaRDD at <unknown>:0"]; } subgraph cluster5506 { label="DeserializeToObject"; 2467 [labelType="html" label="MapPartitionsRDD [2467] toJavaRDD at <unknown>:0"]; } subgraph cluster5505 { label="MapPartitions"; 2468 [labelType="html" label="MapPartitionsRDD [2468] toJavaRDD at <unknown>:0"]; } subgraph cluster5515 { label="mapPartitions"; 2470 [labelType="html" label="MapPartitionsRDD [2470] toJavaRDD at <unknown>:0"]; } } 2457->2458; 2458->2459; 2459->2460; 2460->2461; 2461->2462; 2462->2463; 2463->2464; 2464->2465; 2465->2466; 2466->2467; 2467->2468; 2468->2469; 2469->2470; 2470->2471; }

Event Timeline

Enable zooming