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

digraph G { subgraph clusterstage_1788 { label="Stage 1788"; 18778 [labelType="html" label="SQLExecutionRDD [18778] run at <unknown>:0"]; 18786 [labelType="html" label="SQLExecutionRDD [18786] toJavaRDD at <unknown>:0"]; 18788 [labelType="html" label="PythonRDD [18788] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster42023 { label="MicroBatchScan"; 18774 [labelType="html" label="DataSourceRDD [18774] run at <unknown>:0"]; 18775 [labelType="html" label="MapPartitionsRDD [18775] run at <unknown>:0"]; } subgraph cluster42022 { label="Project"; 18776 [labelType="html" label="MapPartitionsRDD [18776] run at <unknown>:0"]; } subgraph cluster42018 { label="WholeStageCodegen (1)"; 18777 [labelType="html" label="MapPartitionsRDD [18777] run at <unknown>:0"]; } subgraph cluster42032 { label="WholeStageCodegen (1)"; 18779 [labelType="html" label="MapPartitionsRDD [18779] toJavaRDD at <unknown>:0"]; } subgraph cluster42031 { label="Filter"; 18780 [labelType="html" label="MapPartitionsRDD [18780] toJavaRDD at <unknown>:0"]; } subgraph cluster42030 { label="Project"; 18781 [labelType="html" label="MapPartitionsRDD [18781] toJavaRDD at <unknown>:0"]; } subgraph cluster42027 { label="WholeStageCodegen (2)"; 18782 [labelType="html" label="MapPartitionsRDD [18782] toJavaRDD at <unknown>:0"]; } subgraph cluster42026 { label="Project"; 18783 [labelType="html" label="MapPartitionsRDD [18783] toJavaRDD at <unknown>:0"]; } subgraph cluster42025 { label="DeserializeToObject"; 18784 [labelType="html" label="MapPartitionsRDD [18784] toJavaRDD at <unknown>:0"]; } subgraph cluster42024 { label="MapPartitions"; 18785 [labelType="html" label="MapPartitionsRDD [18785] toJavaRDD at <unknown>:0"]; } subgraph cluster42034 { label="mapPartitions"; 18787 [labelType="html" label="MapPartitionsRDD [18787] toJavaRDD at <unknown>:0"]; } } 18774->18775; 18775->18776; 18776->18777; 18777->18778; 18778->18779; 18779->18780; 18780->18781; 18781->18782; 18782->18783; 18783->18784; 18784->18785; 18785->18786; 18786->18787; 18787->18788; }

Event Timeline

Enable zooming