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

digraph G { subgraph clusterstage_1387 { label="Stage 1387"; 14579 [labelType="html" label="SQLExecutionRDD [14579] run at <unknown>:0"]; 14587 [labelType="html" label="SQLExecutionRDD [14587] toJavaRDD at <unknown>:0"]; 14589 [labelType="html" label="PythonRDD [14589] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster32619 { label="MicroBatchScan"; 14575 [labelType="html" label="DataSourceRDD [14575] run at <unknown>:0"]; 14576 [labelType="html" label="MapPartitionsRDD [14576] run at <unknown>:0"]; } subgraph cluster32618 { label="Project"; 14577 [labelType="html" label="MapPartitionsRDD [14577] run at <unknown>:0"]; } subgraph cluster32614 { label="WholeStageCodegen (1)"; 14578 [labelType="html" label="MapPartitionsRDD [14578] run at <unknown>:0"]; } subgraph cluster32628 { label="WholeStageCodegen (1)"; 14580 [labelType="html" label="MapPartitionsRDD [14580] toJavaRDD at <unknown>:0"]; } subgraph cluster32627 { label="Filter"; 14581 [labelType="html" label="MapPartitionsRDD [14581] toJavaRDD at <unknown>:0"]; } subgraph cluster32626 { label="Project"; 14582 [labelType="html" label="MapPartitionsRDD [14582] toJavaRDD at <unknown>:0"]; } subgraph cluster32623 { label="WholeStageCodegen (2)"; 14583 [labelType="html" label="MapPartitionsRDD [14583] toJavaRDD at <unknown>:0"]; } subgraph cluster32622 { label="Project"; 14584 [labelType="html" label="MapPartitionsRDD [14584] toJavaRDD at <unknown>:0"]; } subgraph cluster32621 { label="DeserializeToObject"; 14585 [labelType="html" label="MapPartitionsRDD [14585] toJavaRDD at <unknown>:0"]; } subgraph cluster32620 { label="MapPartitions"; 14586 [labelType="html" label="MapPartitionsRDD [14586] toJavaRDD at <unknown>:0"]; } subgraph cluster32630 { label="mapPartitions"; 14588 [labelType="html" label="MapPartitionsRDD [14588] toJavaRDD at <unknown>:0"]; } } 14575->14576; 14576->14577; 14577->14578; 14578->14579; 14579->14580; 14580->14581; 14581->14582; 14582->14583; 14583->14584; 14584->14585; 14585->14586; 14586->14587; 14587->14588; 14588->14589; }

Event Timeline

Enable zooming