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

digraph G { subgraph clusterstage_527 { label="Stage 527"; 5527 [labelType="html" label="SQLExecutionRDD [5527] run at <unknown>:0"]; 5541 [labelType="html" label="SQLExecutionRDD [5541] toJavaRDD at <unknown>:0"]; 5543 [labelType="html" label="PythonRDD [5543] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster12366 { label="MicroBatchScan"; 5523 [labelType="html" label="DataSourceRDD [5523] run at <unknown>:0"]; 5524 [labelType="html" label="MapPartitionsRDD [5524] run at <unknown>:0"]; } subgraph cluster12365 { label="Project"; 5525 [labelType="html" label="MapPartitionsRDD [5525] run at <unknown>:0"]; } subgraph cluster12361 { label="WholeStageCodegen (1)"; 5526 [labelType="html" label="MapPartitionsRDD [5526] run at <unknown>:0"]; } subgraph cluster12383 { label="WholeStageCodegen (1)"; 5534 [labelType="html" label="MapPartitionsRDD [5534] toJavaRDD at <unknown>:0"]; } subgraph cluster12382 { label="Filter"; 5535 [labelType="html" label="MapPartitionsRDD [5535] toJavaRDD at <unknown>:0"]; } subgraph cluster12381 { label="Project"; 5536 [labelType="html" label="MapPartitionsRDD [5536] toJavaRDD at <unknown>:0"]; } subgraph cluster12378 { label="WholeStageCodegen (2)"; 5537 [labelType="html" label="MapPartitionsRDD [5537] toJavaRDD at <unknown>:0"]; } subgraph cluster12377 { label="Project"; 5538 [labelType="html" label="MapPartitionsRDD [5538] toJavaRDD at <unknown>:0"]; } subgraph cluster12376 { label="DeserializeToObject"; 5539 [labelType="html" label="MapPartitionsRDD [5539] toJavaRDD at <unknown>:0"]; } subgraph cluster12375 { label="MapPartitions"; 5540 [labelType="html" label="MapPartitionsRDD [5540] toJavaRDD at <unknown>:0"]; } subgraph cluster12385 { label="mapPartitions"; 5542 [labelType="html" label="MapPartitionsRDD [5542] toJavaRDD at <unknown>:0"]; } } 5523->5524; 5524->5525; 5525->5526; 5526->5527; 5527->5534; 5534->5535; 5535->5536; 5536->5537; 5537->5538; 5538->5539; 5539->5540; 5540->5541; 5541->5542; 5542->5543; }

Event Timeline

Enable zooming