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

digraph G { subgraph clusterstage_1454 { label="Stage 1454"; 15271 [labelType="html" label="SQLExecutionRDD [15271] run at <unknown>:0"]; 15279 [labelType="html" label="SQLExecutionRDD [15279] toJavaRDD at <unknown>:0"]; 15281 [labelType="html" label="PythonRDD [15281] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster34174 { label="MicroBatchScan"; 15267 [labelType="html" label="DataSourceRDD [15267] run at <unknown>:0"]; 15268 [labelType="html" label="MapPartitionsRDD [15268] run at <unknown>:0"]; } subgraph cluster34173 { label="Project"; 15269 [labelType="html" label="MapPartitionsRDD [15269] run at <unknown>:0"]; } subgraph cluster34169 { label="WholeStageCodegen (1)"; 15270 [labelType="html" label="MapPartitionsRDD [15270] run at <unknown>:0"]; } subgraph cluster34183 { label="WholeStageCodegen (1)"; 15272 [labelType="html" label="MapPartitionsRDD [15272] toJavaRDD at <unknown>:0"]; } subgraph cluster34182 { label="Filter"; 15273 [labelType="html" label="MapPartitionsRDD [15273] toJavaRDD at <unknown>:0"]; } subgraph cluster34181 { label="Project"; 15274 [labelType="html" label="MapPartitionsRDD [15274] toJavaRDD at <unknown>:0"]; } subgraph cluster34178 { label="WholeStageCodegen (2)"; 15275 [labelType="html" label="MapPartitionsRDD [15275] toJavaRDD at <unknown>:0"]; } subgraph cluster34177 { label="Project"; 15276 [labelType="html" label="MapPartitionsRDD [15276] toJavaRDD at <unknown>:0"]; } subgraph cluster34176 { label="DeserializeToObject"; 15277 [labelType="html" label="MapPartitionsRDD [15277] toJavaRDD at <unknown>:0"]; } subgraph cluster34175 { label="MapPartitions"; 15278 [labelType="html" label="MapPartitionsRDD [15278] toJavaRDD at <unknown>:0"]; } subgraph cluster34185 { label="mapPartitions"; 15280 [labelType="html" label="MapPartitionsRDD [15280] toJavaRDD at <unknown>:0"]; } } 15267->15268; 15268->15269; 15269->15270; 15270->15271; 15271->15272; 15272->15273; 15273->15274; 15274->15275; 15275->15276; 15276->15277; 15277->15278; 15278->15279; 15279->15280; 15280->15281; }

Event Timeline

Enable zooming