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

digraph G { subgraph clusterstage_1292 { label="Stage 1292"; 13570 [labelType="html" label="SQLExecutionRDD [13570] run at <unknown>:0"]; 13578 [labelType="html" label="SQLExecutionRDD [13578] toJavaRDD at <unknown>:0"]; 13580 [labelType="html" label="PythonRDD [13580] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster30367 { label="MicroBatchScan"; 13566 [labelType="html" label="DataSourceRDD [13566] run at <unknown>:0"]; 13567 [labelType="html" label="MapPartitionsRDD [13567] run at <unknown>:0"]; } subgraph cluster30366 { label="Project"; 13568 [labelType="html" label="MapPartitionsRDD [13568] run at <unknown>:0"]; } subgraph cluster30362 { label="WholeStageCodegen (1)"; 13569 [labelType="html" label="MapPartitionsRDD [13569] run at <unknown>:0"]; } subgraph cluster30376 { label="WholeStageCodegen (1)"; 13571 [labelType="html" label="MapPartitionsRDD [13571] toJavaRDD at <unknown>:0"]; } subgraph cluster30375 { label="Filter"; 13572 [labelType="html" label="MapPartitionsRDD [13572] toJavaRDD at <unknown>:0"]; } subgraph cluster30374 { label="Project"; 13573 [labelType="html" label="MapPartitionsRDD [13573] toJavaRDD at <unknown>:0"]; } subgraph cluster30371 { label="WholeStageCodegen (2)"; 13574 [labelType="html" label="MapPartitionsRDD [13574] toJavaRDD at <unknown>:0"]; } subgraph cluster30370 { label="Project"; 13575 [labelType="html" label="MapPartitionsRDD [13575] toJavaRDD at <unknown>:0"]; } subgraph cluster30369 { label="DeserializeToObject"; 13576 [labelType="html" label="MapPartitionsRDD [13576] toJavaRDD at <unknown>:0"]; } subgraph cluster30368 { label="MapPartitions"; 13577 [labelType="html" label="MapPartitionsRDD [13577] toJavaRDD at <unknown>:0"]; } subgraph cluster30378 { label="mapPartitions"; 13579 [labelType="html" label="MapPartitionsRDD [13579] toJavaRDD at <unknown>:0"]; } } 13566->13567; 13567->13568; 13568->13569; 13569->13570; 13570->13571; 13571->13572; 13572->13573; 13573->13574; 13574->13575; 13575->13576; 13576->13577; 13577->13578; 13578->13579; 13579->13580; }

Event Timeline

Enable zooming