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

digraph G { subgraph clusterstage_1225 { label="Stage 1225"; 12878 [labelType="html" label="SQLExecutionRDD [12878] run at <unknown>:0"]; 12886 [labelType="html" label="SQLExecutionRDD [12886] toJavaRDD at <unknown>:0"]; 12888 [labelType="html" label="PythonRDD [12888] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster28812 { label="MicroBatchScan"; 12874 [labelType="html" label="DataSourceRDD [12874] run at <unknown>:0"]; 12875 [labelType="html" label="MapPartitionsRDD [12875] run at <unknown>:0"]; } subgraph cluster28811 { label="Project"; 12876 [labelType="html" label="MapPartitionsRDD [12876] run at <unknown>:0"]; } subgraph cluster28807 { label="WholeStageCodegen (1)"; 12877 [labelType="html" label="MapPartitionsRDD [12877] run at <unknown>:0"]; } subgraph cluster28821 { label="WholeStageCodegen (1)"; 12879 [labelType="html" label="MapPartitionsRDD [12879] toJavaRDD at <unknown>:0"]; } subgraph cluster28820 { label="Filter"; 12880 [labelType="html" label="MapPartitionsRDD [12880] toJavaRDD at <unknown>:0"]; } subgraph cluster28819 { label="Project"; 12881 [labelType="html" label="MapPartitionsRDD [12881] toJavaRDD at <unknown>:0"]; } subgraph cluster28816 { label="WholeStageCodegen (2)"; 12882 [labelType="html" label="MapPartitionsRDD [12882] toJavaRDD at <unknown>:0"]; } subgraph cluster28815 { label="Project"; 12883 [labelType="html" label="MapPartitionsRDD [12883] toJavaRDD at <unknown>:0"]; } subgraph cluster28814 { label="DeserializeToObject"; 12884 [labelType="html" label="MapPartitionsRDD [12884] toJavaRDD at <unknown>:0"]; } subgraph cluster28813 { label="MapPartitions"; 12885 [labelType="html" label="MapPartitionsRDD [12885] toJavaRDD at <unknown>:0"]; } subgraph cluster28823 { label="mapPartitions"; 12887 [labelType="html" label="MapPartitionsRDD [12887] toJavaRDD at <unknown>:0"]; } } 12874->12875; 12875->12876; 12876->12877; 12877->12878; 12878->12879; 12879->12880; 12880->12881; 12881->12882; 12882->12883; 12883->12884; 12884->12885; 12885->12886; 12886->12887; 12887->12888; }

Event Timeline

Enable zooming