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

digraph G { subgraph clusterstage_524 { label="Stage 524"; 5506 [labelType="html" label="SQLExecutionRDD [5506] run at <unknown>:0"]; 5514 [labelType="html" label="SQLExecutionRDD [5514] toJavaRDD at <unknown>:0"]; 5516 [labelType="html" label="PythonRDD [5516] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster12319 { label="MicroBatchScan"; 5502 [labelType="html" label="DataSourceRDD [5502] run at <unknown>:0"]; 5503 [labelType="html" label="MapPartitionsRDD [5503] run at <unknown>:0"]; } subgraph cluster12318 { label="Project"; 5504 [labelType="html" label="MapPartitionsRDD [5504] run at <unknown>:0"]; } subgraph cluster12314 { label="WholeStageCodegen (1)"; 5505 [labelType="html" label="MapPartitionsRDD [5505] run at <unknown>:0"]; } subgraph cluster12328 { label="WholeStageCodegen (1)"; 5507 [labelType="html" label="MapPartitionsRDD [5507] toJavaRDD at <unknown>:0"]; } subgraph cluster12327 { label="Filter"; 5508 [labelType="html" label="MapPartitionsRDD [5508] toJavaRDD at <unknown>:0"]; } subgraph cluster12326 { label="Project"; 5509 [labelType="html" label="MapPartitionsRDD [5509] toJavaRDD at <unknown>:0"]; } subgraph cluster12323 { label="WholeStageCodegen (2)"; 5510 [labelType="html" label="MapPartitionsRDD [5510] toJavaRDD at <unknown>:0"]; } subgraph cluster12322 { label="Project"; 5511 [labelType="html" label="MapPartitionsRDD [5511] toJavaRDD at <unknown>:0"]; } subgraph cluster12321 { label="DeserializeToObject"; 5512 [labelType="html" label="MapPartitionsRDD [5512] toJavaRDD at <unknown>:0"]; } subgraph cluster12320 { label="MapPartitions"; 5513 [labelType="html" label="MapPartitionsRDD [5513] toJavaRDD at <unknown>:0"]; } subgraph cluster12330 { label="mapPartitions"; 5515 [labelType="html" label="MapPartitionsRDD [5515] toJavaRDD at <unknown>:0"]; } } 5502->5503; 5503->5504; 5504->5505; 5505->5506; 5506->5507; 5507->5508; 5508->5509; 5509->5510; 5510->5511; 5511->5512; 5512->5513; 5513->5514; 5514->5515; 5515->5516; }

Event Timeline

Enable zooming