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

digraph G { subgraph clusterstage_927 { label="Stage 927"; 9749 [labelType="html" label="SQLExecutionRDD [9749] run at <unknown>:0"]; 9757 [labelType="html" label="SQLExecutionRDD [9757] toJavaRDD at <unknown>:0"]; 9759 [labelType="html" label="PythonRDD [9759] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster21809 { label="MicroBatchScan"; 9745 [labelType="html" label="DataSourceRDD [9745] run at <unknown>:0"]; 9746 [labelType="html" label="MapPartitionsRDD [9746] run at <unknown>:0"]; } subgraph cluster21808 { label="Project"; 9747 [labelType="html" label="MapPartitionsRDD [9747] run at <unknown>:0"]; } subgraph cluster21804 { label="WholeStageCodegen (1)"; 9748 [labelType="html" label="MapPartitionsRDD [9748] run at <unknown>:0"]; } subgraph cluster21818 { label="WholeStageCodegen (1)"; 9750 [labelType="html" label="MapPartitionsRDD [9750] toJavaRDD at <unknown>:0"]; } subgraph cluster21817 { label="Filter"; 9751 [labelType="html" label="MapPartitionsRDD [9751] toJavaRDD at <unknown>:0"]; } subgraph cluster21816 { label="Project"; 9752 [labelType="html" label="MapPartitionsRDD [9752] toJavaRDD at <unknown>:0"]; } subgraph cluster21813 { label="WholeStageCodegen (2)"; 9753 [labelType="html" label="MapPartitionsRDD [9753] toJavaRDD at <unknown>:0"]; } subgraph cluster21812 { label="Project"; 9754 [labelType="html" label="MapPartitionsRDD [9754] toJavaRDD at <unknown>:0"]; } subgraph cluster21811 { label="DeserializeToObject"; 9755 [labelType="html" label="MapPartitionsRDD [9755] toJavaRDD at <unknown>:0"]; } subgraph cluster21810 { label="MapPartitions"; 9756 [labelType="html" label="MapPartitionsRDD [9756] toJavaRDD at <unknown>:0"]; } subgraph cluster21820 { label="mapPartitions"; 9758 [labelType="html" label="MapPartitionsRDD [9758] toJavaRDD at <unknown>:0"]; } } 9745->9746; 9746->9747; 9747->9748; 9748->9749; 9749->9750; 9750->9751; 9751->9752; 9752->9753; 9753->9754; 9754->9755; 9755->9756; 9756->9757; 9757->9758; 9758->9759; }

Event Timeline

Enable zooming