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

digraph G { subgraph clusterstage_1609 { label="Stage 1609"; 16910 [labelType="html" label="SQLExecutionRDD [16910] run at <unknown>:0"]; 16918 [labelType="html" label="SQLExecutionRDD [16918] toJavaRDD at <unknown>:0"]; 16920 [labelType="html" label="PythonRDD [16920] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster37836 { label="MicroBatchScan"; 16906 [labelType="html" label="DataSourceRDD [16906] run at <unknown>:0"]; 16907 [labelType="html" label="MapPartitionsRDD [16907] run at <unknown>:0"]; } subgraph cluster37835 { label="Project"; 16908 [labelType="html" label="MapPartitionsRDD [16908] run at <unknown>:0"]; } subgraph cluster37831 { label="WholeStageCodegen (1)"; 16909 [labelType="html" label="MapPartitionsRDD [16909] run at <unknown>:0"]; } subgraph cluster37845 { label="WholeStageCodegen (1)"; 16911 [labelType="html" label="MapPartitionsRDD [16911] toJavaRDD at <unknown>:0"]; } subgraph cluster37844 { label="Filter"; 16912 [labelType="html" label="MapPartitionsRDD [16912] toJavaRDD at <unknown>:0"]; } subgraph cluster37843 { label="Project"; 16913 [labelType="html" label="MapPartitionsRDD [16913] toJavaRDD at <unknown>:0"]; } subgraph cluster37840 { label="WholeStageCodegen (2)"; 16914 [labelType="html" label="MapPartitionsRDD [16914] toJavaRDD at <unknown>:0"]; } subgraph cluster37839 { label="Project"; 16915 [labelType="html" label="MapPartitionsRDD [16915] toJavaRDD at <unknown>:0"]; } subgraph cluster37838 { label="DeserializeToObject"; 16916 [labelType="html" label="MapPartitionsRDD [16916] toJavaRDD at <unknown>:0"]; } subgraph cluster37837 { label="MapPartitions"; 16917 [labelType="html" label="MapPartitionsRDD [16917] toJavaRDD at <unknown>:0"]; } subgraph cluster37847 { label="mapPartitions"; 16919 [labelType="html" label="MapPartitionsRDD [16919] toJavaRDD at <unknown>:0"]; } } 16906->16907; 16907->16908; 16908->16909; 16909->16910; 16910->16911; 16911->16912; 16912->16913; 16913->16914; 16914->16915; 16915->16916; 16916->16917; 16917->16918; 16918->16919; 16919->16920; }

Event Timeline

Enable zooming