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

digraph G { subgraph clusterstage_1746 { label="Stage 1746"; 18337 [labelType="html" label="SQLExecutionRDD [18337] run at <unknown>:0"]; 18345 [labelType="html" label="SQLExecutionRDD [18345] toJavaRDD at <unknown>:0"]; 18347 [labelType="html" label="PythonRDD [18347] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster41036 { label="MicroBatchScan"; 18333 [labelType="html" label="DataSourceRDD [18333] run at <unknown>:0"]; 18334 [labelType="html" label="MapPartitionsRDD [18334] run at <unknown>:0"]; } subgraph cluster41035 { label="Project"; 18335 [labelType="html" label="MapPartitionsRDD [18335] run at <unknown>:0"]; } subgraph cluster41031 { label="WholeStageCodegen (1)"; 18336 [labelType="html" label="MapPartitionsRDD [18336] run at <unknown>:0"]; } subgraph cluster41045 { label="WholeStageCodegen (1)"; 18338 [labelType="html" label="MapPartitionsRDD [18338] toJavaRDD at <unknown>:0"]; } subgraph cluster41044 { label="Filter"; 18339 [labelType="html" label="MapPartitionsRDD [18339] toJavaRDD at <unknown>:0"]; } subgraph cluster41043 { label="Project"; 18340 [labelType="html" label="MapPartitionsRDD [18340] toJavaRDD at <unknown>:0"]; } subgraph cluster41040 { label="WholeStageCodegen (2)"; 18341 [labelType="html" label="MapPartitionsRDD [18341] toJavaRDD at <unknown>:0"]; } subgraph cluster41039 { label="Project"; 18342 [labelType="html" label="MapPartitionsRDD [18342] toJavaRDD at <unknown>:0"]; } subgraph cluster41038 { label="DeserializeToObject"; 18343 [labelType="html" label="MapPartitionsRDD [18343] toJavaRDD at <unknown>:0"]; } subgraph cluster41037 { label="MapPartitions"; 18344 [labelType="html" label="MapPartitionsRDD [18344] toJavaRDD at <unknown>:0"]; } subgraph cluster41047 { label="mapPartitions"; 18346 [labelType="html" label="MapPartitionsRDD [18346] toJavaRDD at <unknown>:0"]; } } 18333->18334; 18334->18335; 18335->18336; 18336->18337; 18337->18338; 18338->18339; 18339->18340; 18340->18341; 18341->18342; 18342->18343; 18343->18344; 18344->18345; 18345->18346; 18346->18347; }

Event Timeline

Enable zooming