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

digraph G { subgraph clusterstage_1373 { label="Stage 1373"; 14432 [labelType="html" label="SQLExecutionRDD [14432] run at <unknown>:0"]; 14440 [labelType="html" label="SQLExecutionRDD [14440] toJavaRDD at <unknown>:0"]; 14442 [labelType="html" label="PythonRDD [14442] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster32290 { label="MicroBatchScan"; 14428 [labelType="html" label="DataSourceRDD [14428] run at <unknown>:0"]; 14429 [labelType="html" label="MapPartitionsRDD [14429] run at <unknown>:0"]; } subgraph cluster32289 { label="Project"; 14430 [labelType="html" label="MapPartitionsRDD [14430] run at <unknown>:0"]; } subgraph cluster32285 { label="WholeStageCodegen (1)"; 14431 [labelType="html" label="MapPartitionsRDD [14431] run at <unknown>:0"]; } subgraph cluster32299 { label="WholeStageCodegen (1)"; 14433 [labelType="html" label="MapPartitionsRDD [14433] toJavaRDD at <unknown>:0"]; } subgraph cluster32298 { label="Filter"; 14434 [labelType="html" label="MapPartitionsRDD [14434] toJavaRDD at <unknown>:0"]; } subgraph cluster32297 { label="Project"; 14435 [labelType="html" label="MapPartitionsRDD [14435] toJavaRDD at <unknown>:0"]; } subgraph cluster32294 { label="WholeStageCodegen (2)"; 14436 [labelType="html" label="MapPartitionsRDD [14436] toJavaRDD at <unknown>:0"]; } subgraph cluster32293 { label="Project"; 14437 [labelType="html" label="MapPartitionsRDD [14437] toJavaRDD at <unknown>:0"]; } subgraph cluster32292 { label="DeserializeToObject"; 14438 [labelType="html" label="MapPartitionsRDD [14438] toJavaRDD at <unknown>:0"]; } subgraph cluster32291 { label="MapPartitions"; 14439 [labelType="html" label="MapPartitionsRDD [14439] toJavaRDD at <unknown>:0"]; } subgraph cluster32301 { label="mapPartitions"; 14441 [labelType="html" label="MapPartitionsRDD [14441] toJavaRDD at <unknown>:0"]; } } 14428->14429; 14429->14430; 14430->14431; 14431->14432; 14432->14433; 14433->14434; 14434->14435; 14435->14436; 14436->14437; 14437->14438; 14438->14439; 14439->14440; 14440->14441; 14441->14442; }

Event Timeline

Enable zooming