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

digraph G { subgraph clusterstage_1704 { label="Stage 1704"; 17903 [labelType="html" label="SQLExecutionRDD [17903] run at <unknown>:0"]; 17911 [labelType="html" label="SQLExecutionRDD [17911] toJavaRDD at <unknown>:0"]; 17913 [labelType="html" label="PythonRDD [17913] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster40053 { label="MicroBatchScan"; 17899 [labelType="html" label="DataSourceRDD [17899] run at <unknown>:0"]; 17900 [labelType="html" label="MapPartitionsRDD [17900] run at <unknown>:0"]; } subgraph cluster40052 { label="Project"; 17901 [labelType="html" label="MapPartitionsRDD [17901] run at <unknown>:0"]; } subgraph cluster40048 { label="WholeStageCodegen (1)"; 17902 [labelType="html" label="MapPartitionsRDD [17902] run at <unknown>:0"]; } subgraph cluster40062 { label="WholeStageCodegen (1)"; 17904 [labelType="html" label="MapPartitionsRDD [17904] toJavaRDD at <unknown>:0"]; } subgraph cluster40061 { label="Filter"; 17905 [labelType="html" label="MapPartitionsRDD [17905] toJavaRDD at <unknown>:0"]; } subgraph cluster40060 { label="Project"; 17906 [labelType="html" label="MapPartitionsRDD [17906] toJavaRDD at <unknown>:0"]; } subgraph cluster40057 { label="WholeStageCodegen (2)"; 17907 [labelType="html" label="MapPartitionsRDD [17907] toJavaRDD at <unknown>:0"]; } subgraph cluster40056 { label="Project"; 17908 [labelType="html" label="MapPartitionsRDD [17908] toJavaRDD at <unknown>:0"]; } subgraph cluster40055 { label="DeserializeToObject"; 17909 [labelType="html" label="MapPartitionsRDD [17909] toJavaRDD at <unknown>:0"]; } subgraph cluster40054 { label="MapPartitions"; 17910 [labelType="html" label="MapPartitionsRDD [17910] toJavaRDD at <unknown>:0"]; } subgraph cluster40064 { label="mapPartitions"; 17912 [labelType="html" label="MapPartitionsRDD [17912] toJavaRDD at <unknown>:0"]; } } 17899->17900; 17900->17901; 17901->17902; 17902->17903; 17903->17904; 17904->17905; 17905->17906; 17906->17907; 17907->17908; 17908->17909; 17909->17910; 17910->17911; 17911->17912; 17912->17913; }

Event Timeline

Enable zooming