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

digraph G { subgraph clusterstage_1800 { label="Stage 1800"; 18904 [labelType="html" label="SQLExecutionRDD [18904] run at <unknown>:0"]; 18912 [labelType="html" label="SQLExecutionRDD [18912] toJavaRDD at <unknown>:0"]; 18914 [labelType="html" label="PythonRDD [18914] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster42305 { label="MicroBatchScan"; 18900 [labelType="html" label="DataSourceRDD [18900] run at <unknown>:0"]; 18901 [labelType="html" label="MapPartitionsRDD [18901] run at <unknown>:0"]; } subgraph cluster42304 { label="Project"; 18902 [labelType="html" label="MapPartitionsRDD [18902] run at <unknown>:0"]; } subgraph cluster42300 { label="WholeStageCodegen (1)"; 18903 [labelType="html" label="MapPartitionsRDD [18903] run at <unknown>:0"]; } subgraph cluster42314 { label="WholeStageCodegen (1)"; 18905 [labelType="html" label="MapPartitionsRDD [18905] toJavaRDD at <unknown>:0"]; } subgraph cluster42313 { label="Filter"; 18906 [labelType="html" label="MapPartitionsRDD [18906] toJavaRDD at <unknown>:0"]; } subgraph cluster42312 { label="Project"; 18907 [labelType="html" label="MapPartitionsRDD [18907] toJavaRDD at <unknown>:0"]; } subgraph cluster42309 { label="WholeStageCodegen (2)"; 18908 [labelType="html" label="MapPartitionsRDD [18908] toJavaRDD at <unknown>:0"]; } subgraph cluster42308 { label="Project"; 18909 [labelType="html" label="MapPartitionsRDD [18909] toJavaRDD at <unknown>:0"]; } subgraph cluster42307 { label="DeserializeToObject"; 18910 [labelType="html" label="MapPartitionsRDD [18910] toJavaRDD at <unknown>:0"]; } subgraph cluster42306 { label="MapPartitions"; 18911 [labelType="html" label="MapPartitionsRDD [18911] toJavaRDD at <unknown>:0"]; } subgraph cluster42316 { label="mapPartitions"; 18913 [labelType="html" label="MapPartitionsRDD [18913] toJavaRDD at <unknown>:0"]; } } 18900->18901; 18901->18902; 18902->18903; 18903->18904; 18904->18905; 18905->18906; 18906->18907; 18907->18908; 18908->18909; 18909->18910; 18910->18911; 18911->18912; 18912->18913; 18913->18914; }

Event Timeline

Enable zooming