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

digraph G { subgraph clusterstage_1554 { label="Stage 1554"; 16328 [labelType="html" label="SQLExecutionRDD [16328] run at <unknown>:0"]; 16336 [labelType="html" label="SQLExecutionRDD [16336] toJavaRDD at <unknown>:0"]; 16338 [labelType="html" label="PythonRDD [16338] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster36528 { label="MicroBatchScan"; 16324 [labelType="html" label="DataSourceRDD [16324] run at <unknown>:0"]; 16325 [labelType="html" label="MapPartitionsRDD [16325] run at <unknown>:0"]; } subgraph cluster36527 { label="Project"; 16326 [labelType="html" label="MapPartitionsRDD [16326] run at <unknown>:0"]; } subgraph cluster36523 { label="WholeStageCodegen (1)"; 16327 [labelType="html" label="MapPartitionsRDD [16327] run at <unknown>:0"]; } subgraph cluster36537 { label="WholeStageCodegen (1)"; 16329 [labelType="html" label="MapPartitionsRDD [16329] toJavaRDD at <unknown>:0"]; } subgraph cluster36536 { label="Filter"; 16330 [labelType="html" label="MapPartitionsRDD [16330] toJavaRDD at <unknown>:0"]; } subgraph cluster36535 { label="Project"; 16331 [labelType="html" label="MapPartitionsRDD [16331] toJavaRDD at <unknown>:0"]; } subgraph cluster36532 { label="WholeStageCodegen (2)"; 16332 [labelType="html" label="MapPartitionsRDD [16332] toJavaRDD at <unknown>:0"]; } subgraph cluster36531 { label="Project"; 16333 [labelType="html" label="MapPartitionsRDD [16333] toJavaRDD at <unknown>:0"]; } subgraph cluster36530 { label="DeserializeToObject"; 16334 [labelType="html" label="MapPartitionsRDD [16334] toJavaRDD at <unknown>:0"]; } subgraph cluster36529 { label="MapPartitions"; 16335 [labelType="html" label="MapPartitionsRDD [16335] toJavaRDD at <unknown>:0"]; } subgraph cluster36539 { label="mapPartitions"; 16337 [labelType="html" label="MapPartitionsRDD [16337] toJavaRDD at <unknown>:0"]; } } 16324->16325; 16325->16326; 16326->16327; 16327->16328; 16328->16329; 16329->16330; 16330->16331; 16331->16332; 16332->16333; 16333->16334; 16334->16335; 16335->16336; 16336->16337; 16337->16338; }

Event Timeline

Enable zooming