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

digraph G { subgraph clusterstage_1868 { label="Stage 1868"; 19618 [labelType="html" label="SQLExecutionRDD [19618] run at <unknown>:0"]; 19626 [labelType="html" label="SQLExecutionRDD [19626] toJavaRDD at <unknown>:0"]; 19628 [labelType="html" label="PythonRDD [19628] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster43903 { label="MicroBatchScan"; 19614 [labelType="html" label="DataSourceRDD [19614] run at <unknown>:0"]; 19615 [labelType="html" label="MapPartitionsRDD [19615] run at <unknown>:0"]; } subgraph cluster43902 { label="Project"; 19616 [labelType="html" label="MapPartitionsRDD [19616] run at <unknown>:0"]; } subgraph cluster43898 { label="WholeStageCodegen (1)"; 19617 [labelType="html" label="MapPartitionsRDD [19617] run at <unknown>:0"]; } subgraph cluster43912 { label="WholeStageCodegen (1)"; 19619 [labelType="html" label="MapPartitionsRDD [19619] toJavaRDD at <unknown>:0"]; } subgraph cluster43911 { label="Filter"; 19620 [labelType="html" label="MapPartitionsRDD [19620] toJavaRDD at <unknown>:0"]; } subgraph cluster43910 { label="Project"; 19621 [labelType="html" label="MapPartitionsRDD [19621] toJavaRDD at <unknown>:0"]; } subgraph cluster43907 { label="WholeStageCodegen (2)"; 19622 [labelType="html" label="MapPartitionsRDD [19622] toJavaRDD at <unknown>:0"]; } subgraph cluster43906 { label="Project"; 19623 [labelType="html" label="MapPartitionsRDD [19623] toJavaRDD at <unknown>:0"]; } subgraph cluster43905 { label="DeserializeToObject"; 19624 [labelType="html" label="MapPartitionsRDD [19624] toJavaRDD at <unknown>:0"]; } subgraph cluster43904 { label="MapPartitions"; 19625 [labelType="html" label="MapPartitionsRDD [19625] toJavaRDD at <unknown>:0"]; } subgraph cluster43914 { label="mapPartitions"; 19627 [labelType="html" label="MapPartitionsRDD [19627] toJavaRDD at <unknown>:0"]; } } 19614->19615; 19615->19616; 19616->19617; 19617->19618; 19618->19619; 19619->19620; 19620->19621; 19621->19622; 19622->19623; 19623->19624; 19624->19625; 19625->19626; 19626->19627; 19627->19628; }

Event Timeline

Enable zooming