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

digraph G { subgraph clusterstage_1970 { label="Stage 1970"; 20690 [labelType="html" label="SQLExecutionRDD [20690] run at <unknown>:0"]; 20704 [labelType="html" label="SQLExecutionRDD [20704] toJavaRDD at <unknown>:0"]; 20706 [labelType="html" label="PythonRDD [20706] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster46296 { label="MicroBatchScan"; 20686 [labelType="html" label="DataSourceRDD [20686] run at <unknown>:0"]; 20687 [labelType="html" label="MapPartitionsRDD [20687] run at <unknown>:0"]; } subgraph cluster46295 { label="Project"; 20688 [labelType="html" label="MapPartitionsRDD [20688] run at <unknown>:0"]; } subgraph cluster46291 { label="WholeStageCodegen (1)"; 20689 [labelType="html" label="MapPartitionsRDD [20689] run at <unknown>:0"]; } subgraph cluster46313 { label="WholeStageCodegen (1)"; 20697 [labelType="html" label="MapPartitionsRDD [20697] toJavaRDD at <unknown>:0"]; } subgraph cluster46312 { label="Filter"; 20698 [labelType="html" label="MapPartitionsRDD [20698] toJavaRDD at <unknown>:0"]; } subgraph cluster46311 { label="Project"; 20699 [labelType="html" label="MapPartitionsRDD [20699] toJavaRDD at <unknown>:0"]; } subgraph cluster46308 { label="WholeStageCodegen (2)"; 20700 [labelType="html" label="MapPartitionsRDD [20700] toJavaRDD at <unknown>:0"]; } subgraph cluster46307 { label="Project"; 20701 [labelType="html" label="MapPartitionsRDD [20701] toJavaRDD at <unknown>:0"]; } subgraph cluster46306 { label="DeserializeToObject"; 20702 [labelType="html" label="MapPartitionsRDD [20702] toJavaRDD at <unknown>:0"]; } subgraph cluster46305 { label="MapPartitions"; 20703 [labelType="html" label="MapPartitionsRDD [20703] toJavaRDD at <unknown>:0"]; } subgraph cluster46315 { label="mapPartitions"; 20705 [labelType="html" label="MapPartitionsRDD [20705] toJavaRDD at <unknown>:0"]; } } 20686->20687; 20687->20688; 20688->20689; 20689->20690; 20690->20697; 20697->20698; 20698->20699; 20699->20700; 20700->20701; 20701->20702; 20702->20703; 20703->20704; 20704->20705; 20705->20706; }

Event Timeline

Enable zooming