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

digraph G { subgraph clusterstage_1215 { label="Stage 1215"; 12773 [labelType="html" label="SQLExecutionRDD [12773] run at <unknown>:0"]; 12781 [labelType="html" label="SQLExecutionRDD [12781] toJavaRDD at <unknown>:0"]; 12783 [labelType="html" label="PythonRDD [12783] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster28577 { label="MicroBatchScan"; 12769 [labelType="html" label="DataSourceRDD [12769] run at <unknown>:0"]; 12770 [labelType="html" label="MapPartitionsRDD [12770] run at <unknown>:0"]; } subgraph cluster28576 { label="Project"; 12771 [labelType="html" label="MapPartitionsRDD [12771] run at <unknown>:0"]; } subgraph cluster28572 { label="WholeStageCodegen (1)"; 12772 [labelType="html" label="MapPartitionsRDD [12772] run at <unknown>:0"]; } subgraph cluster28586 { label="WholeStageCodegen (1)"; 12774 [labelType="html" label="MapPartitionsRDD [12774] toJavaRDD at <unknown>:0"]; } subgraph cluster28585 { label="Filter"; 12775 [labelType="html" label="MapPartitionsRDD [12775] toJavaRDD at <unknown>:0"]; } subgraph cluster28584 { label="Project"; 12776 [labelType="html" label="MapPartitionsRDD [12776] toJavaRDD at <unknown>:0"]; } subgraph cluster28581 { label="WholeStageCodegen (2)"; 12777 [labelType="html" label="MapPartitionsRDD [12777] toJavaRDD at <unknown>:0"]; } subgraph cluster28580 { label="Project"; 12778 [labelType="html" label="MapPartitionsRDD [12778] toJavaRDD at <unknown>:0"]; } subgraph cluster28579 { label="DeserializeToObject"; 12779 [labelType="html" label="MapPartitionsRDD [12779] toJavaRDD at <unknown>:0"]; } subgraph cluster28578 { label="MapPartitions"; 12780 [labelType="html" label="MapPartitionsRDD [12780] toJavaRDD at <unknown>:0"]; } subgraph cluster28588 { label="mapPartitions"; 12782 [labelType="html" label="MapPartitionsRDD [12782] toJavaRDD at <unknown>:0"]; } } 12769->12770; 12770->12771; 12771->12772; 12772->12773; 12773->12774; 12774->12775; 12775->12776; 12776->12777; 12777->12778; 12778->12779; 12779->12780; 12780->12781; 12781->12782; 12782->12783; }

Event Timeline

Enable zooming