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

digraph G { subgraph clusterstage_1973 { label="Stage 1973"; 20732 [labelType="html" label="SQLExecutionRDD [20732] run at <unknown>:0"]; 20740 [labelType="html" label="SQLExecutionRDD [20740] toJavaRDD at <unknown>:0"]; 20742 [labelType="html" label="PythonRDD [20742] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster46390 { label="MicroBatchScan"; 20728 [labelType="html" label="DataSourceRDD [20728] run at <unknown>:0"]; 20729 [labelType="html" label="MapPartitionsRDD [20729] run at <unknown>:0"]; } subgraph cluster46389 { label="Project"; 20730 [labelType="html" label="MapPartitionsRDD [20730] run at <unknown>:0"]; } subgraph cluster46385 { label="WholeStageCodegen (1)"; 20731 [labelType="html" label="MapPartitionsRDD [20731] run at <unknown>:0"]; } subgraph cluster46399 { label="WholeStageCodegen (1)"; 20733 [labelType="html" label="MapPartitionsRDD [20733] toJavaRDD at <unknown>:0"]; } subgraph cluster46398 { label="Filter"; 20734 [labelType="html" label="MapPartitionsRDD [20734] toJavaRDD at <unknown>:0"]; } subgraph cluster46397 { label="Project"; 20735 [labelType="html" label="MapPartitionsRDD [20735] toJavaRDD at <unknown>:0"]; } subgraph cluster46394 { label="WholeStageCodegen (2)"; 20736 [labelType="html" label="MapPartitionsRDD [20736] toJavaRDD at <unknown>:0"]; } subgraph cluster46393 { label="Project"; 20737 [labelType="html" label="MapPartitionsRDD [20737] toJavaRDD at <unknown>:0"]; } subgraph cluster46392 { label="DeserializeToObject"; 20738 [labelType="html" label="MapPartitionsRDD [20738] toJavaRDD at <unknown>:0"]; } subgraph cluster46391 { label="MapPartitions"; 20739 [labelType="html" label="MapPartitionsRDD [20739] toJavaRDD at <unknown>:0"]; } subgraph cluster46401 { label="mapPartitions"; 20741 [labelType="html" label="MapPartitionsRDD [20741] toJavaRDD at <unknown>:0"]; } } 20728->20729; 20729->20730; 20730->20731; 20731->20732; 20732->20733; 20733->20734; 20734->20735; 20735->20736; 20736->20737; 20737->20738; 20738->20739; 20739->20740; 20740->20741; 20741->20742; }

Event Timeline

Enable zooming