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

digraph G { subgraph clusterstage_508 { label="Stage 508"; 5338 [labelType="html" label="SQLExecutionRDD [5338] run at <unknown>:0"]; 5346 [labelType="html" label="SQLExecutionRDD [5346] toJavaRDD at <unknown>:0"]; 5348 [labelType="html" label="PythonRDD [5348] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster11943 { label="MicroBatchScan"; 5334 [labelType="html" label="DataSourceRDD [5334] run at <unknown>:0"]; 5335 [labelType="html" label="MapPartitionsRDD [5335] run at <unknown>:0"]; } subgraph cluster11942 { label="Project"; 5336 [labelType="html" label="MapPartitionsRDD [5336] run at <unknown>:0"]; } subgraph cluster11938 { label="WholeStageCodegen (1)"; 5337 [labelType="html" label="MapPartitionsRDD [5337] run at <unknown>:0"]; } subgraph cluster11952 { label="WholeStageCodegen (1)"; 5339 [labelType="html" label="MapPartitionsRDD [5339] toJavaRDD at <unknown>:0"]; } subgraph cluster11951 { label="Filter"; 5340 [labelType="html" label="MapPartitionsRDD [5340] toJavaRDD at <unknown>:0"]; } subgraph cluster11950 { label="Project"; 5341 [labelType="html" label="MapPartitionsRDD [5341] toJavaRDD at <unknown>:0"]; } subgraph cluster11947 { label="WholeStageCodegen (2)"; 5342 [labelType="html" label="MapPartitionsRDD [5342] toJavaRDD at <unknown>:0"]; } subgraph cluster11946 { label="Project"; 5343 [labelType="html" label="MapPartitionsRDD [5343] toJavaRDD at <unknown>:0"]; } subgraph cluster11945 { label="DeserializeToObject"; 5344 [labelType="html" label="MapPartitionsRDD [5344] toJavaRDD at <unknown>:0"]; } subgraph cluster11944 { label="MapPartitions"; 5345 [labelType="html" label="MapPartitionsRDD [5345] toJavaRDD at <unknown>:0"]; } subgraph cluster11954 { label="mapPartitions"; 5347 [labelType="html" label="MapPartitionsRDD [5347] toJavaRDD at <unknown>:0"]; } } 5334->5335; 5335->5336; 5336->5337; 5337->5338; 5338->5339; 5339->5340; 5340->5341; 5341->5342; 5342->5343; 5343->5344; 5344->5345; 5345->5346; 5346->5347; 5347->5348; }

Event Timeline

Enable zooming