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

digraph G { subgraph clusterstage_1375 { label="Stage 1375"; 14453 [labelType="html" label="SQLExecutionRDD [14453] run at <unknown>:0"]; 14461 [labelType="html" label="SQLExecutionRDD [14461] toJavaRDD at <unknown>:0"]; 14463 [labelType="html" label="PythonRDD [14463] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster32337 { label="MicroBatchScan"; 14449 [labelType="html" label="DataSourceRDD [14449] run at <unknown>:0"]; 14450 [labelType="html" label="MapPartitionsRDD [14450] run at <unknown>:0"]; } subgraph cluster32336 { label="Project"; 14451 [labelType="html" label="MapPartitionsRDD [14451] run at <unknown>:0"]; } subgraph cluster32332 { label="WholeStageCodegen (1)"; 14452 [labelType="html" label="MapPartitionsRDD [14452] run at <unknown>:0"]; } subgraph cluster32346 { label="WholeStageCodegen (1)"; 14454 [labelType="html" label="MapPartitionsRDD [14454] toJavaRDD at <unknown>:0"]; } subgraph cluster32345 { label="Filter"; 14455 [labelType="html" label="MapPartitionsRDD [14455] toJavaRDD at <unknown>:0"]; } subgraph cluster32344 { label="Project"; 14456 [labelType="html" label="MapPartitionsRDD [14456] toJavaRDD at <unknown>:0"]; } subgraph cluster32341 { label="WholeStageCodegen (2)"; 14457 [labelType="html" label="MapPartitionsRDD [14457] toJavaRDD at <unknown>:0"]; } subgraph cluster32340 { label="Project"; 14458 [labelType="html" label="MapPartitionsRDD [14458] toJavaRDD at <unknown>:0"]; } subgraph cluster32339 { label="DeserializeToObject"; 14459 [labelType="html" label="MapPartitionsRDD [14459] toJavaRDD at <unknown>:0"]; } subgraph cluster32338 { label="MapPartitions"; 14460 [labelType="html" label="MapPartitionsRDD [14460] toJavaRDD at <unknown>:0"]; } subgraph cluster32348 { label="mapPartitions"; 14462 [labelType="html" label="MapPartitionsRDD [14462] toJavaRDD at <unknown>:0"]; } } 14449->14450; 14450->14451; 14451->14452; 14452->14453; 14453->14454; 14454->14455; 14455->14456; 14456->14457; 14457->14458; 14458->14459; 14459->14460; 14460->14461; 14461->14462; 14462->14463; }

Event Timeline

Enable zooming