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

digraph G { subgraph clusterstage_1270 { label="Stage 1270"; 13339 [labelType="html" label="SQLExecutionRDD [13339] run at <unknown>:0"]; 13347 [labelType="html" label="SQLExecutionRDD [13347] toJavaRDD at <unknown>:0"]; 13349 [labelType="html" label="PythonRDD [13349] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster29850 { label="MicroBatchScan"; 13335 [labelType="html" label="DataSourceRDD [13335] run at <unknown>:0"]; 13336 [labelType="html" label="MapPartitionsRDD [13336] run at <unknown>:0"]; } subgraph cluster29849 { label="Project"; 13337 [labelType="html" label="MapPartitionsRDD [13337] run at <unknown>:0"]; } subgraph cluster29845 { label="WholeStageCodegen (1)"; 13338 [labelType="html" label="MapPartitionsRDD [13338] run at <unknown>:0"]; } subgraph cluster29859 { label="WholeStageCodegen (1)"; 13340 [labelType="html" label="MapPartitionsRDD [13340] toJavaRDD at <unknown>:0"]; } subgraph cluster29858 { label="Filter"; 13341 [labelType="html" label="MapPartitionsRDD [13341] toJavaRDD at <unknown>:0"]; } subgraph cluster29857 { label="Project"; 13342 [labelType="html" label="MapPartitionsRDD [13342] toJavaRDD at <unknown>:0"]; } subgraph cluster29854 { label="WholeStageCodegen (2)"; 13343 [labelType="html" label="MapPartitionsRDD [13343] toJavaRDD at <unknown>:0"]; } subgraph cluster29853 { label="Project"; 13344 [labelType="html" label="MapPartitionsRDD [13344] toJavaRDD at <unknown>:0"]; } subgraph cluster29852 { label="DeserializeToObject"; 13345 [labelType="html" label="MapPartitionsRDD [13345] toJavaRDD at <unknown>:0"]; } subgraph cluster29851 { label="MapPartitions"; 13346 [labelType="html" label="MapPartitionsRDD [13346] toJavaRDD at <unknown>:0"]; } subgraph cluster29861 { label="mapPartitions"; 13348 [labelType="html" label="MapPartitionsRDD [13348] toJavaRDD at <unknown>:0"]; } } 13335->13336; 13336->13337; 13337->13338; 13338->13339; 13339->13340; 13340->13341; 13341->13342; 13342->13343; 13343->13344; 13344->13345; 13345->13346; 13346->13347; 13347->13348; 13348->13349; }

Event Timeline

Enable zooming