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

digraph G { subgraph clusterstage_1643 { label="Stage 1643"; 17267 [labelType="html" label="SQLExecutionRDD [17267] run at <unknown>:0"]; 17275 [labelType="html" label="SQLExecutionRDD [17275] toJavaRDD at <unknown>:0"]; 17277 [labelType="html" label="PythonRDD [17277] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster38635 { label="MicroBatchScan"; 17263 [labelType="html" label="DataSourceRDD [17263] run at <unknown>:0"]; 17264 [labelType="html" label="MapPartitionsRDD [17264] run at <unknown>:0"]; } subgraph cluster38634 { label="Project"; 17265 [labelType="html" label="MapPartitionsRDD [17265] run at <unknown>:0"]; } subgraph cluster38630 { label="WholeStageCodegen (1)"; 17266 [labelType="html" label="MapPartitionsRDD [17266] run at <unknown>:0"]; } subgraph cluster38644 { label="WholeStageCodegen (1)"; 17268 [labelType="html" label="MapPartitionsRDD [17268] toJavaRDD at <unknown>:0"]; } subgraph cluster38643 { label="Filter"; 17269 [labelType="html" label="MapPartitionsRDD [17269] toJavaRDD at <unknown>:0"]; } subgraph cluster38642 { label="Project"; 17270 [labelType="html" label="MapPartitionsRDD [17270] toJavaRDD at <unknown>:0"]; } subgraph cluster38639 { label="WholeStageCodegen (2)"; 17271 [labelType="html" label="MapPartitionsRDD [17271] toJavaRDD at <unknown>:0"]; } subgraph cluster38638 { label="Project"; 17272 [labelType="html" label="MapPartitionsRDD [17272] toJavaRDD at <unknown>:0"]; } subgraph cluster38637 { label="DeserializeToObject"; 17273 [labelType="html" label="MapPartitionsRDD [17273] toJavaRDD at <unknown>:0"]; } subgraph cluster38636 { label="MapPartitions"; 17274 [labelType="html" label="MapPartitionsRDD [17274] toJavaRDD at <unknown>:0"]; } subgraph cluster38646 { label="mapPartitions"; 17276 [labelType="html" label="MapPartitionsRDD [17276] toJavaRDD at <unknown>:0"]; } } 17263->17264; 17264->17265; 17265->17266; 17266->17267; 17267->17268; 17268->17269; 17269->17270; 17270->17271; 17271->17272; 17272->17273; 17273->17274; 17274->17275; 17275->17276; 17276->17277; }

Event Timeline

Enable zooming