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

digraph G { subgraph clusterstage_1514 { label="Stage 1514"; 15901 [labelType="html" label="SQLExecutionRDD [15901] run at <unknown>:0"]; 15909 [labelType="html" label="SQLExecutionRDD [15909] toJavaRDD at <unknown>:0"]; 15911 [labelType="html" label="PythonRDD [15911] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster35584 { label="MicroBatchScan"; 15897 [labelType="html" label="DataSourceRDD [15897] run at <unknown>:0"]; 15898 [labelType="html" label="MapPartitionsRDD [15898] run at <unknown>:0"]; } subgraph cluster35583 { label="Project"; 15899 [labelType="html" label="MapPartitionsRDD [15899] run at <unknown>:0"]; } subgraph cluster35579 { label="WholeStageCodegen (1)"; 15900 [labelType="html" label="MapPartitionsRDD [15900] run at <unknown>:0"]; } subgraph cluster35593 { label="WholeStageCodegen (1)"; 15902 [labelType="html" label="MapPartitionsRDD [15902] toJavaRDD at <unknown>:0"]; } subgraph cluster35592 { label="Filter"; 15903 [labelType="html" label="MapPartitionsRDD [15903] toJavaRDD at <unknown>:0"]; } subgraph cluster35591 { label="Project"; 15904 [labelType="html" label="MapPartitionsRDD [15904] toJavaRDD at <unknown>:0"]; } subgraph cluster35588 { label="WholeStageCodegen (2)"; 15905 [labelType="html" label="MapPartitionsRDD [15905] toJavaRDD at <unknown>:0"]; } subgraph cluster35587 { label="Project"; 15906 [labelType="html" label="MapPartitionsRDD [15906] toJavaRDD at <unknown>:0"]; } subgraph cluster35586 { label="DeserializeToObject"; 15907 [labelType="html" label="MapPartitionsRDD [15907] toJavaRDD at <unknown>:0"]; } subgraph cluster35585 { label="MapPartitions"; 15908 [labelType="html" label="MapPartitionsRDD [15908] toJavaRDD at <unknown>:0"]; } subgraph cluster35595 { label="mapPartitions"; 15910 [labelType="html" label="MapPartitionsRDD [15910] toJavaRDD at <unknown>:0"]; } } 15897->15898; 15898->15899; 15899->15900; 15900->15901; 15901->15902; 15902->15903; 15903->15904; 15904->15905; 15905->15906; 15906->15907; 15907->15908; 15908->15909; 15909->15910; 15910->15911; }

Event Timeline

Enable zooming