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

digraph G { subgraph clusterstage_1893 { label="Stage 1893"; 19870 [labelType="html" label="SQLExecutionRDD [19870] run at <unknown>:0"]; 19884 [labelType="html" label="SQLExecutionRDD [19884] toJavaRDD at <unknown>:0"]; 19886 [labelType="html" label="PythonRDD [19886] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster44467 { label="MicroBatchScan"; 19866 [labelType="html" label="DataSourceRDD [19866] run at <unknown>:0"]; 19867 [labelType="html" label="MapPartitionsRDD [19867] run at <unknown>:0"]; } subgraph cluster44466 { label="Project"; 19868 [labelType="html" label="MapPartitionsRDD [19868] run at <unknown>:0"]; } subgraph cluster44462 { label="WholeStageCodegen (1)"; 19869 [labelType="html" label="MapPartitionsRDD [19869] run at <unknown>:0"]; } subgraph cluster44484 { label="WholeStageCodegen (1)"; 19877 [labelType="html" label="MapPartitionsRDD [19877] toJavaRDD at <unknown>:0"]; } subgraph cluster44483 { label="Filter"; 19878 [labelType="html" label="MapPartitionsRDD [19878] toJavaRDD at <unknown>:0"]; } subgraph cluster44482 { label="Project"; 19879 [labelType="html" label="MapPartitionsRDD [19879] toJavaRDD at <unknown>:0"]; } subgraph cluster44479 { label="WholeStageCodegen (2)"; 19880 [labelType="html" label="MapPartitionsRDD [19880] toJavaRDD at <unknown>:0"]; } subgraph cluster44478 { label="Project"; 19881 [labelType="html" label="MapPartitionsRDD [19881] toJavaRDD at <unknown>:0"]; } subgraph cluster44477 { label="DeserializeToObject"; 19882 [labelType="html" label="MapPartitionsRDD [19882] toJavaRDD at <unknown>:0"]; } subgraph cluster44476 { label="MapPartitions"; 19883 [labelType="html" label="MapPartitionsRDD [19883] toJavaRDD at <unknown>:0"]; } subgraph cluster44486 { label="mapPartitions"; 19885 [labelType="html" label="MapPartitionsRDD [19885] toJavaRDD at <unknown>:0"]; } } 19866->19867; 19867->19868; 19868->19869; 19869->19870; 19870->19877; 19877->19878; 19878->19879; 19879->19880; 19880->19881; 19881->19882; 19882->19883; 19883->19884; 19884->19885; 19885->19886; }

Event Timeline

Enable zooming