processing-stream-kafka-raw-to-minio - Details for Stage 1077 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 4
Input Size / Records: 0.0 B / 443
Associated Job Ids: 1078

digraph G { subgraph clusterstage_1077 { label="Stage 1077"; 11324 [labelType="html" label="SQLExecutionRDD [11324] run at <unknown>:0"]; 11332 [labelType="html" label="SQLExecutionRDD [11332] toJavaRDD at <unknown>:0"]; 11334 [labelType="html" label="PythonRDD [11334] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster25334 { label="MicroBatchScan"; 11320 [labelType="html" label="DataSourceRDD [11320] run at <unknown>:0"]; 11321 [labelType="html" label="MapPartitionsRDD [11321] run at <unknown>:0"]; } subgraph cluster25333 { label="Project"; 11322 [labelType="html" label="MapPartitionsRDD [11322] run at <unknown>:0"]; } subgraph cluster25329 { label="WholeStageCodegen (1)"; 11323 [labelType="html" label="MapPartitionsRDD [11323] run at <unknown>:0"]; } subgraph cluster25343 { label="WholeStageCodegen (1)"; 11325 [labelType="html" label="MapPartitionsRDD [11325] toJavaRDD at <unknown>:0"]; } subgraph cluster25342 { label="Filter"; 11326 [labelType="html" label="MapPartitionsRDD [11326] toJavaRDD at <unknown>:0"]; } subgraph cluster25341 { label="Project"; 11327 [labelType="html" label="MapPartitionsRDD [11327] toJavaRDD at <unknown>:0"]; } subgraph cluster25338 { label="WholeStageCodegen (2)"; 11328 [labelType="html" label="MapPartitionsRDD [11328] toJavaRDD at <unknown>:0"]; } subgraph cluster25337 { label="Project"; 11329 [labelType="html" label="MapPartitionsRDD [11329] toJavaRDD at <unknown>:0"]; } subgraph cluster25336 { label="DeserializeToObject"; 11330 [labelType="html" label="MapPartitionsRDD [11330] toJavaRDD at <unknown>:0"]; } subgraph cluster25335 { label="MapPartitions"; 11331 [labelType="html" label="MapPartitionsRDD [11331] toJavaRDD at <unknown>:0"]; } subgraph cluster25345 { label="mapPartitions"; 11333 [labelType="html" label="MapPartitionsRDD [11333] toJavaRDD at <unknown>:0"]; } } 11320->11321; 11321->11322; 11322->11323; 11323->11324; 11324->11325; 11325->11326; 11326->11327; 11327->11328; 11328->11329; 11329->11330; 11330->11331; 11331->11332; 11332->11333; 11333->11334; }

Event Timeline

Enable zooming