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

digraph G { subgraph clusterstage_751 { label="Stage 751"; 7901 [labelType="html" label="SQLExecutionRDD [7901] run at <unknown>:0"]; 7909 [labelType="html" label="SQLExecutionRDD [7909] toJavaRDD at <unknown>:0"]; 7911 [labelType="html" label="PythonRDD [7911] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster17673 { label="MicroBatchScan"; 7897 [labelType="html" label="DataSourceRDD [7897] run at <unknown>:0"]; 7898 [labelType="html" label="MapPartitionsRDD [7898] run at <unknown>:0"]; } subgraph cluster17672 { label="Project"; 7899 [labelType="html" label="MapPartitionsRDD [7899] run at <unknown>:0"]; } subgraph cluster17668 { label="WholeStageCodegen (1)"; 7900 [labelType="html" label="MapPartitionsRDD [7900] run at <unknown>:0"]; } subgraph cluster17682 { label="WholeStageCodegen (1)"; 7902 [labelType="html" label="MapPartitionsRDD [7902] toJavaRDD at <unknown>:0"]; } subgraph cluster17681 { label="Filter"; 7903 [labelType="html" label="MapPartitionsRDD [7903] toJavaRDD at <unknown>:0"]; } subgraph cluster17680 { label="Project"; 7904 [labelType="html" label="MapPartitionsRDD [7904] toJavaRDD at <unknown>:0"]; } subgraph cluster17677 { label="WholeStageCodegen (2)"; 7905 [labelType="html" label="MapPartitionsRDD [7905] toJavaRDD at <unknown>:0"]; } subgraph cluster17676 { label="Project"; 7906 [labelType="html" label="MapPartitionsRDD [7906] toJavaRDD at <unknown>:0"]; } subgraph cluster17675 { label="DeserializeToObject"; 7907 [labelType="html" label="MapPartitionsRDD [7907] toJavaRDD at <unknown>:0"]; } subgraph cluster17674 { label="MapPartitions"; 7908 [labelType="html" label="MapPartitionsRDD [7908] toJavaRDD at <unknown>:0"]; } subgraph cluster17684 { label="mapPartitions"; 7910 [labelType="html" label="MapPartitionsRDD [7910] toJavaRDD at <unknown>:0"]; } } 7897->7898; 7898->7899; 7899->7900; 7900->7901; 7901->7902; 7902->7903; 7903->7904; 7904->7905; 7905->7906; 7906->7907; 7907->7908; 7908->7909; 7909->7910; 7910->7911; }

Event Timeline

Enable zooming