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

digraph G { subgraph clusterstage_519 { label="Stage 519"; 5443 [labelType="html" label="SQLExecutionRDD [5443] run at <unknown>:0"]; 5457 [labelType="html" label="SQLExecutionRDD [5457] toJavaRDD at <unknown>:0"]; 5459 [labelType="html" label="PythonRDD [5459] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster12178 { label="MicroBatchScan"; 5439 [labelType="html" label="DataSourceRDD [5439] run at <unknown>:0"]; 5440 [labelType="html" label="MapPartitionsRDD [5440] run at <unknown>:0"]; } subgraph cluster12177 { label="Project"; 5441 [labelType="html" label="MapPartitionsRDD [5441] run at <unknown>:0"]; } subgraph cluster12173 { label="WholeStageCodegen (1)"; 5442 [labelType="html" label="MapPartitionsRDD [5442] run at <unknown>:0"]; } subgraph cluster12195 { label="WholeStageCodegen (1)"; 5450 [labelType="html" label="MapPartitionsRDD [5450] toJavaRDD at <unknown>:0"]; } subgraph cluster12194 { label="Filter"; 5451 [labelType="html" label="MapPartitionsRDD [5451] toJavaRDD at <unknown>:0"]; } subgraph cluster12193 { label="Project"; 5452 [labelType="html" label="MapPartitionsRDD [5452] toJavaRDD at <unknown>:0"]; } subgraph cluster12190 { label="WholeStageCodegen (2)"; 5453 [labelType="html" label="MapPartitionsRDD [5453] toJavaRDD at <unknown>:0"]; } subgraph cluster12189 { label="Project"; 5454 [labelType="html" label="MapPartitionsRDD [5454] toJavaRDD at <unknown>:0"]; } subgraph cluster12188 { label="DeserializeToObject"; 5455 [labelType="html" label="MapPartitionsRDD [5455] toJavaRDD at <unknown>:0"]; } subgraph cluster12187 { label="MapPartitions"; 5456 [labelType="html" label="MapPartitionsRDD [5456] toJavaRDD at <unknown>:0"]; } subgraph cluster12197 { label="mapPartitions"; 5458 [labelType="html" label="MapPartitionsRDD [5458] toJavaRDD at <unknown>:0"]; } } 5439->5440; 5440->5441; 5441->5442; 5442->5443; 5443->5450; 5450->5451; 5451->5452; 5452->5453; 5453->5454; 5454->5455; 5455->5456; 5456->5457; 5457->5458; 5458->5459; }

Event Timeline

Enable zooming