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

digraph G { subgraph clusterstage_1880 { label="Stage 1880"; 19744 [labelType="html" label="SQLExecutionRDD [19744] run at <unknown>:0"]; 19752 [labelType="html" label="SQLExecutionRDD [19752] toJavaRDD at <unknown>:0"]; 19754 [labelType="html" label="PythonRDD [19754] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster44185 { label="MicroBatchScan"; 19740 [labelType="html" label="DataSourceRDD [19740] run at <unknown>:0"]; 19741 [labelType="html" label="MapPartitionsRDD [19741] run at <unknown>:0"]; } subgraph cluster44184 { label="Project"; 19742 [labelType="html" label="MapPartitionsRDD [19742] run at <unknown>:0"]; } subgraph cluster44180 { label="WholeStageCodegen (1)"; 19743 [labelType="html" label="MapPartitionsRDD [19743] run at <unknown>:0"]; } subgraph cluster44194 { label="WholeStageCodegen (1)"; 19745 [labelType="html" label="MapPartitionsRDD [19745] toJavaRDD at <unknown>:0"]; } subgraph cluster44193 { label="Filter"; 19746 [labelType="html" label="MapPartitionsRDD [19746] toJavaRDD at <unknown>:0"]; } subgraph cluster44192 { label="Project"; 19747 [labelType="html" label="MapPartitionsRDD [19747] toJavaRDD at <unknown>:0"]; } subgraph cluster44189 { label="WholeStageCodegen (2)"; 19748 [labelType="html" label="MapPartitionsRDD [19748] toJavaRDD at <unknown>:0"]; } subgraph cluster44188 { label="Project"; 19749 [labelType="html" label="MapPartitionsRDD [19749] toJavaRDD at <unknown>:0"]; } subgraph cluster44187 { label="DeserializeToObject"; 19750 [labelType="html" label="MapPartitionsRDD [19750] toJavaRDD at <unknown>:0"]; } subgraph cluster44186 { label="MapPartitions"; 19751 [labelType="html" label="MapPartitionsRDD [19751] toJavaRDD at <unknown>:0"]; } subgraph cluster44196 { label="mapPartitions"; 19753 [labelType="html" label="MapPartitionsRDD [19753] toJavaRDD at <unknown>:0"]; } } 19740->19741; 19741->19742; 19742->19743; 19743->19744; 19744->19745; 19745->19746; 19746->19747; 19747->19748; 19748->19749; 19749->19750; 19750->19751; 19751->19752; 19752->19753; 19753->19754; }

Event Timeline

Enable zooming