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

digraph G { subgraph clusterstage_316 { label="Stage 316"; 3322 [labelType="html" label="SQLExecutionRDD [3322] run at <unknown>:0"]; 3330 [labelType="html" label="SQLExecutionRDD [3330] toJavaRDD at <unknown>:0"]; 3332 [labelType="html" label="PythonRDD [3332] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster7431 { label="MicroBatchScan"; 3318 [labelType="html" label="DataSourceRDD [3318] run at <unknown>:0"]; 3319 [labelType="html" label="MapPartitionsRDD [3319] run at <unknown>:0"]; } subgraph cluster7430 { label="Project"; 3320 [labelType="html" label="MapPartitionsRDD [3320] run at <unknown>:0"]; } subgraph cluster7426 { label="WholeStageCodegen (1)"; 3321 [labelType="html" label="MapPartitionsRDD [3321] run at <unknown>:0"]; } subgraph cluster7440 { label="WholeStageCodegen (1)"; 3323 [labelType="html" label="MapPartitionsRDD [3323] toJavaRDD at <unknown>:0"]; } subgraph cluster7439 { label="Filter"; 3324 [labelType="html" label="MapPartitionsRDD [3324] toJavaRDD at <unknown>:0"]; } subgraph cluster7438 { label="Project"; 3325 [labelType="html" label="MapPartitionsRDD [3325] toJavaRDD at <unknown>:0"]; } subgraph cluster7435 { label="WholeStageCodegen (2)"; 3326 [labelType="html" label="MapPartitionsRDD [3326] toJavaRDD at <unknown>:0"]; } subgraph cluster7434 { label="Project"; 3327 [labelType="html" label="MapPartitionsRDD [3327] toJavaRDD at <unknown>:0"]; } subgraph cluster7433 { label="DeserializeToObject"; 3328 [labelType="html" label="MapPartitionsRDD [3328] toJavaRDD at <unknown>:0"]; } subgraph cluster7432 { label="MapPartitions"; 3329 [labelType="html" label="MapPartitionsRDD [3329] toJavaRDD at <unknown>:0"]; } subgraph cluster7442 { label="mapPartitions"; 3331 [labelType="html" label="MapPartitionsRDD [3331] toJavaRDD at <unknown>:0"]; } } 3318->3319; 3319->3320; 3320->3321; 3321->3322; 3322->3323; 3323->3324; 3324->3325; 3325->3326; 3326->3327; 3327->3328; 3328->3329; 3329->3330; 3330->3331; 3331->3332; }

Event Timeline

Enable zooming