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

digraph G { subgraph clusterstage_1579 { label="Stage 1579"; 16595 [labelType="html" label="SQLExecutionRDD [16595] run at <unknown>:0"]; 16603 [labelType="html" label="SQLExecutionRDD [16603] toJavaRDD at <unknown>:0"]; 16605 [labelType="html" label="PythonRDD [16605] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster37131 { label="MicroBatchScan"; 16591 [labelType="html" label="DataSourceRDD [16591] run at <unknown>:0"]; 16592 [labelType="html" label="MapPartitionsRDD [16592] run at <unknown>:0"]; } subgraph cluster37130 { label="Project"; 16593 [labelType="html" label="MapPartitionsRDD [16593] run at <unknown>:0"]; } subgraph cluster37126 { label="WholeStageCodegen (1)"; 16594 [labelType="html" label="MapPartitionsRDD [16594] run at <unknown>:0"]; } subgraph cluster37140 { label="WholeStageCodegen (1)"; 16596 [labelType="html" label="MapPartitionsRDD [16596] toJavaRDD at <unknown>:0"]; } subgraph cluster37139 { label="Filter"; 16597 [labelType="html" label="MapPartitionsRDD [16597] toJavaRDD at <unknown>:0"]; } subgraph cluster37138 { label="Project"; 16598 [labelType="html" label="MapPartitionsRDD [16598] toJavaRDD at <unknown>:0"]; } subgraph cluster37135 { label="WholeStageCodegen (2)"; 16599 [labelType="html" label="MapPartitionsRDD [16599] toJavaRDD at <unknown>:0"]; } subgraph cluster37134 { label="Project"; 16600 [labelType="html" label="MapPartitionsRDD [16600] toJavaRDD at <unknown>:0"]; } subgraph cluster37133 { label="DeserializeToObject"; 16601 [labelType="html" label="MapPartitionsRDD [16601] toJavaRDD at <unknown>:0"]; } subgraph cluster37132 { label="MapPartitions"; 16602 [labelType="html" label="MapPartitionsRDD [16602] toJavaRDD at <unknown>:0"]; } subgraph cluster37142 { label="mapPartitions"; 16604 [labelType="html" label="MapPartitionsRDD [16604] toJavaRDD at <unknown>:0"]; } } 16591->16592; 16592->16593; 16593->16594; 16594->16595; 16595->16596; 16596->16597; 16597->16598; 16598->16599; 16599->16600; 16600->16601; 16601->16602; 16602->16603; 16603->16604; 16604->16605; }

Event Timeline

Enable zooming