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

digraph G { subgraph clusterstage_1988 { label="Stage 1988"; 20885 [labelType="html" label="SQLExecutionRDD [20885] run at <unknown>:0"]; 20893 [labelType="html" label="SQLExecutionRDD [20893] toJavaRDD at <unknown>:0"]; 20895 [labelType="html" label="PythonRDD [20895] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster46727 { label="MicroBatchScan"; 20881 [labelType="html" label="DataSourceRDD [20881] run at <unknown>:0"]; 20882 [labelType="html" label="MapPartitionsRDD [20882] run at <unknown>:0"]; } subgraph cluster46726 { label="Project"; 20883 [labelType="html" label="MapPartitionsRDD [20883] run at <unknown>:0"]; } subgraph cluster46722 { label="WholeStageCodegen (1)"; 20884 [labelType="html" label="MapPartitionsRDD [20884] run at <unknown>:0"]; } subgraph cluster46736 { label="WholeStageCodegen (1)"; 20886 [labelType="html" label="MapPartitionsRDD [20886] toJavaRDD at <unknown>:0"]; } subgraph cluster46735 { label="Filter"; 20887 [labelType="html" label="MapPartitionsRDD [20887] toJavaRDD at <unknown>:0"]; } subgraph cluster46734 { label="Project"; 20888 [labelType="html" label="MapPartitionsRDD [20888] toJavaRDD at <unknown>:0"]; } subgraph cluster46731 { label="WholeStageCodegen (2)"; 20889 [labelType="html" label="MapPartitionsRDD [20889] toJavaRDD at <unknown>:0"]; } subgraph cluster46730 { label="Project"; 20890 [labelType="html" label="MapPartitionsRDD [20890] toJavaRDD at <unknown>:0"]; } subgraph cluster46729 { label="DeserializeToObject"; 20891 [labelType="html" label="MapPartitionsRDD [20891] toJavaRDD at <unknown>:0"]; } subgraph cluster46728 { label="MapPartitions"; 20892 [labelType="html" label="MapPartitionsRDD [20892] toJavaRDD at <unknown>:0"]; } subgraph cluster46738 { label="mapPartitions"; 20894 [labelType="html" label="MapPartitionsRDD [20894] toJavaRDD at <unknown>:0"]; } } 20881->20882; 20882->20883; 20883->20884; 20884->20885; 20885->20886; 20886->20887; 20887->20888; 20888->20889; 20889->20890; 20890->20891; 20891->20892; 20892->20893; 20893->20894; 20894->20895; }

Event Timeline

Enable zooming