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

digraph G { subgraph clusterstage_929 { label="Stage 929"; 9770 [labelType="html" label="SQLExecutionRDD [9770] run at <unknown>:0"]; 9778 [labelType="html" label="SQLExecutionRDD [9778] toJavaRDD at <unknown>:0"]; 9780 [labelType="html" label="PythonRDD [9780] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster21856 { label="MicroBatchScan"; 9766 [labelType="html" label="DataSourceRDD [9766] run at <unknown>:0"]; 9767 [labelType="html" label="MapPartitionsRDD [9767] run at <unknown>:0"]; } subgraph cluster21855 { label="Project"; 9768 [labelType="html" label="MapPartitionsRDD [9768] run at <unknown>:0"]; } subgraph cluster21851 { label="WholeStageCodegen (1)"; 9769 [labelType="html" label="MapPartitionsRDD [9769] run at <unknown>:0"]; } subgraph cluster21865 { label="WholeStageCodegen (1)"; 9771 [labelType="html" label="MapPartitionsRDD [9771] toJavaRDD at <unknown>:0"]; } subgraph cluster21864 { label="Filter"; 9772 [labelType="html" label="MapPartitionsRDD [9772] toJavaRDD at <unknown>:0"]; } subgraph cluster21863 { label="Project"; 9773 [labelType="html" label="MapPartitionsRDD [9773] toJavaRDD at <unknown>:0"]; } subgraph cluster21860 { label="WholeStageCodegen (2)"; 9774 [labelType="html" label="MapPartitionsRDD [9774] toJavaRDD at <unknown>:0"]; } subgraph cluster21859 { label="Project"; 9775 [labelType="html" label="MapPartitionsRDD [9775] toJavaRDD at <unknown>:0"]; } subgraph cluster21858 { label="DeserializeToObject"; 9776 [labelType="html" label="MapPartitionsRDD [9776] toJavaRDD at <unknown>:0"]; } subgraph cluster21857 { label="MapPartitions"; 9777 [labelType="html" label="MapPartitionsRDD [9777] toJavaRDD at <unknown>:0"]; } subgraph cluster21867 { label="mapPartitions"; 9779 [labelType="html" label="MapPartitionsRDD [9779] toJavaRDD at <unknown>:0"]; } } 9766->9767; 9767->9768; 9768->9769; 9769->9770; 9770->9771; 9771->9772; 9772->9773; 9773->9774; 9774->9775; 9775->9776; 9776->9777; 9777->9778; 9778->9779; 9779->9780; }

Event Timeline

Enable zooming