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

digraph G { subgraph clusterstage_1173 { label="Stage 1173"; 12332 [labelType="html" label="SQLExecutionRDD [12332] run at <unknown>:0"]; 12340 [labelType="html" label="SQLExecutionRDD [12340] toJavaRDD at <unknown>:0"]; 12342 [labelType="html" label="PythonRDD [12342] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster27590 { label="MicroBatchScan"; 12328 [labelType="html" label="DataSourceRDD [12328] run at <unknown>:0"]; 12329 [labelType="html" label="MapPartitionsRDD [12329] run at <unknown>:0"]; } subgraph cluster27589 { label="Project"; 12330 [labelType="html" label="MapPartitionsRDD [12330] run at <unknown>:0"]; } subgraph cluster27585 { label="WholeStageCodegen (1)"; 12331 [labelType="html" label="MapPartitionsRDD [12331] run at <unknown>:0"]; } subgraph cluster27599 { label="WholeStageCodegen (1)"; 12333 [labelType="html" label="MapPartitionsRDD [12333] toJavaRDD at <unknown>:0"]; } subgraph cluster27598 { label="Filter"; 12334 [labelType="html" label="MapPartitionsRDD [12334] toJavaRDD at <unknown>:0"]; } subgraph cluster27597 { label="Project"; 12335 [labelType="html" label="MapPartitionsRDD [12335] toJavaRDD at <unknown>:0"]; } subgraph cluster27594 { label="WholeStageCodegen (2)"; 12336 [labelType="html" label="MapPartitionsRDD [12336] toJavaRDD at <unknown>:0"]; } subgraph cluster27593 { label="Project"; 12337 [labelType="html" label="MapPartitionsRDD [12337] toJavaRDD at <unknown>:0"]; } subgraph cluster27592 { label="DeserializeToObject"; 12338 [labelType="html" label="MapPartitionsRDD [12338] toJavaRDD at <unknown>:0"]; } subgraph cluster27591 { label="MapPartitions"; 12339 [labelType="html" label="MapPartitionsRDD [12339] toJavaRDD at <unknown>:0"]; } subgraph cluster27601 { label="mapPartitions"; 12341 [labelType="html" label="MapPartitionsRDD [12341] toJavaRDD at <unknown>:0"]; } } 12328->12329; 12329->12330; 12330->12331; 12331->12332; 12332->12333; 12333->12334; 12334->12335; 12335->12336; 12336->12337; 12337->12338; 12338->12339; 12339->12340; 12340->12341; 12341->12342; }

Event Timeline

Enable zooming