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

digraph G { subgraph clusterstage_43 { label="Stage 43"; 445 [labelType="html" label="SQLExecutionRDD [445] run at <unknown>:0"]; 459 [labelType="html" label="SQLExecutionRDD [459] toJavaRDD at <unknown>:0"]; 461 [labelType="html" label="PythonRDD [461] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster992 { label="MicroBatchScan"; 441 [labelType="html" label="DataSourceRDD [441] run at <unknown>:0"]; 442 [labelType="html" label="MapPartitionsRDD [442] run at <unknown>:0"]; } subgraph cluster991 { label="Project"; 443 [labelType="html" label="MapPartitionsRDD [443] run at <unknown>:0"]; } subgraph cluster987 { label="WholeStageCodegen (1)"; 444 [labelType="html" label="MapPartitionsRDD [444] run at <unknown>:0"]; } subgraph cluster1009 { label="WholeStageCodegen (1)"; 452 [labelType="html" label="MapPartitionsRDD [452] toJavaRDD at <unknown>:0"]; } subgraph cluster1008 { label="Filter"; 453 [labelType="html" label="MapPartitionsRDD [453] toJavaRDD at <unknown>:0"]; } subgraph cluster1007 { label="Project"; 454 [labelType="html" label="MapPartitionsRDD [454] toJavaRDD at <unknown>:0"]; } subgraph cluster1004 { label="WholeStageCodegen (2)"; 455 [labelType="html" label="MapPartitionsRDD [455] toJavaRDD at <unknown>:0"]; } subgraph cluster1003 { label="Project"; 456 [labelType="html" label="MapPartitionsRDD [456] toJavaRDD at <unknown>:0"]; } subgraph cluster1002 { label="DeserializeToObject"; 457 [labelType="html" label="MapPartitionsRDD [457] toJavaRDD at <unknown>:0"]; } subgraph cluster1001 { label="MapPartitions"; 458 [labelType="html" label="MapPartitionsRDD [458] toJavaRDD at <unknown>:0"]; } subgraph cluster1011 { label="mapPartitions"; 460 [labelType="html" label="MapPartitionsRDD [460] toJavaRDD at <unknown>:0"]; } } 441->442; 442->443; 443->444; 444->445; 445->452; 452->453; 453->454; 454->455; 455->456; 456->457; 457->458; 458->459; 459->460; 460->461; }

Event Timeline

Enable zooming