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

digraph G { subgraph clusterstage_1322 { label="Stage 1322"; 13885 [labelType="html" label="SQLExecutionRDD [13885] run at <unknown>:0"]; 13893 [labelType="html" label="SQLExecutionRDD [13893] toJavaRDD at <unknown>:0"]; 13895 [labelType="html" label="PythonRDD [13895] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster31072 { label="MicroBatchScan"; 13881 [labelType="html" label="DataSourceRDD [13881] run at <unknown>:0"]; 13882 [labelType="html" label="MapPartitionsRDD [13882] run at <unknown>:0"]; } subgraph cluster31071 { label="Project"; 13883 [labelType="html" label="MapPartitionsRDD [13883] run at <unknown>:0"]; } subgraph cluster31067 { label="WholeStageCodegen (1)"; 13884 [labelType="html" label="MapPartitionsRDD [13884] run at <unknown>:0"]; } subgraph cluster31081 { label="WholeStageCodegen (1)"; 13886 [labelType="html" label="MapPartitionsRDD [13886] toJavaRDD at <unknown>:0"]; } subgraph cluster31080 { label="Filter"; 13887 [labelType="html" label="MapPartitionsRDD [13887] toJavaRDD at <unknown>:0"]; } subgraph cluster31079 { label="Project"; 13888 [labelType="html" label="MapPartitionsRDD [13888] toJavaRDD at <unknown>:0"]; } subgraph cluster31076 { label="WholeStageCodegen (2)"; 13889 [labelType="html" label="MapPartitionsRDD [13889] toJavaRDD at <unknown>:0"]; } subgraph cluster31075 { label="Project"; 13890 [labelType="html" label="MapPartitionsRDD [13890] toJavaRDD at <unknown>:0"]; } subgraph cluster31074 { label="DeserializeToObject"; 13891 [labelType="html" label="MapPartitionsRDD [13891] toJavaRDD at <unknown>:0"]; } subgraph cluster31073 { label="MapPartitions"; 13892 [labelType="html" label="MapPartitionsRDD [13892] toJavaRDD at <unknown>:0"]; } subgraph cluster31083 { label="mapPartitions"; 13894 [labelType="html" label="MapPartitionsRDD [13894] toJavaRDD at <unknown>:0"]; } } 13881->13882; 13882->13883; 13883->13884; 13884->13885; 13885->13886; 13886->13887; 13887->13888; 13888->13889; 13889->13890; 13890->13891; 13891->13892; 13892->13893; 13893->13894; 13894->13895; }

Event Timeline

Enable zooming