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

digraph G { subgraph clusterstage_367 { label="Stage 367"; 3853 [labelType="html" label="SQLExecutionRDD [3853] run at <unknown>:0"]; 3861 [labelType="html" label="SQLExecutionRDD [3861] toJavaRDD at <unknown>:0"]; 3863 [labelType="html" label="PythonRDD [3863] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster8614 { label="MicroBatchScan"; 3849 [labelType="html" label="DataSourceRDD [3849] run at <unknown>:0"]; 3850 [labelType="html" label="MapPartitionsRDD [3850] run at <unknown>:0"]; } subgraph cluster8613 { label="Project"; 3851 [labelType="html" label="MapPartitionsRDD [3851] run at <unknown>:0"]; } subgraph cluster8609 { label="WholeStageCodegen (1)"; 3852 [labelType="html" label="MapPartitionsRDD [3852] run at <unknown>:0"]; } subgraph cluster8623 { label="WholeStageCodegen (1)"; 3854 [labelType="html" label="MapPartitionsRDD [3854] toJavaRDD at <unknown>:0"]; } subgraph cluster8622 { label="Filter"; 3855 [labelType="html" label="MapPartitionsRDD [3855] toJavaRDD at <unknown>:0"]; } subgraph cluster8621 { label="Project"; 3856 [labelType="html" label="MapPartitionsRDD [3856] toJavaRDD at <unknown>:0"]; } subgraph cluster8618 { label="WholeStageCodegen (2)"; 3857 [labelType="html" label="MapPartitionsRDD [3857] toJavaRDD at <unknown>:0"]; } subgraph cluster8617 { label="Project"; 3858 [labelType="html" label="MapPartitionsRDD [3858] toJavaRDD at <unknown>:0"]; } subgraph cluster8616 { label="DeserializeToObject"; 3859 [labelType="html" label="MapPartitionsRDD [3859] toJavaRDD at <unknown>:0"]; } subgraph cluster8615 { label="MapPartitions"; 3860 [labelType="html" label="MapPartitionsRDD [3860] toJavaRDD at <unknown>:0"]; } subgraph cluster8625 { label="mapPartitions"; 3862 [labelType="html" label="MapPartitionsRDD [3862] toJavaRDD at <unknown>:0"]; } } 3849->3850; 3850->3851; 3851->3852; 3852->3853; 3853->3854; 3854->3855; 3855->3856; 3856->3857; 3857->3858; 3858->3859; 3859->3860; 3860->3861; 3861->3862; 3862->3863; }

Event Timeline

Enable zooming