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

digraph G { subgraph clusterstage_1864 { label="Stage 1864"; 19576 [labelType="html" label="SQLExecutionRDD [19576] run at <unknown>:0"]; 19584 [labelType="html" label="SQLExecutionRDD [19584] toJavaRDD at <unknown>:0"]; 19586 [labelType="html" label="PythonRDD [19586] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster43809 { label="MicroBatchScan"; 19572 [labelType="html" label="DataSourceRDD [19572] run at <unknown>:0"]; 19573 [labelType="html" label="MapPartitionsRDD [19573] run at <unknown>:0"]; } subgraph cluster43808 { label="Project"; 19574 [labelType="html" label="MapPartitionsRDD [19574] run at <unknown>:0"]; } subgraph cluster43804 { label="WholeStageCodegen (1)"; 19575 [labelType="html" label="MapPartitionsRDD [19575] run at <unknown>:0"]; } subgraph cluster43818 { label="WholeStageCodegen (1)"; 19577 [labelType="html" label="MapPartitionsRDD [19577] toJavaRDD at <unknown>:0"]; } subgraph cluster43817 { label="Filter"; 19578 [labelType="html" label="MapPartitionsRDD [19578] toJavaRDD at <unknown>:0"]; } subgraph cluster43816 { label="Project"; 19579 [labelType="html" label="MapPartitionsRDD [19579] toJavaRDD at <unknown>:0"]; } subgraph cluster43813 { label="WholeStageCodegen (2)"; 19580 [labelType="html" label="MapPartitionsRDD [19580] toJavaRDD at <unknown>:0"]; } subgraph cluster43812 { label="Project"; 19581 [labelType="html" label="MapPartitionsRDD [19581] toJavaRDD at <unknown>:0"]; } subgraph cluster43811 { label="DeserializeToObject"; 19582 [labelType="html" label="MapPartitionsRDD [19582] toJavaRDD at <unknown>:0"]; } subgraph cluster43810 { label="MapPartitions"; 19583 [labelType="html" label="MapPartitionsRDD [19583] toJavaRDD at <unknown>:0"]; } subgraph cluster43820 { label="mapPartitions"; 19585 [labelType="html" label="MapPartitionsRDD [19585] toJavaRDD at <unknown>:0"]; } } 19572->19573; 19573->19574; 19574->19575; 19575->19576; 19576->19577; 19577->19578; 19578->19579; 19579->19580; 19580->19581; 19581->19582; 19582->19583; 19583->19584; 19584->19585; 19585->19586; }

Event Timeline

Enable zooming