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

digraph G { subgraph clusterstage_1327 { label="Stage 1327"; 13933 [labelType="html" label="SQLExecutionRDD [13933] run at <unknown>:0"]; 13941 [labelType="html" label="SQLExecutionRDD [13941] toJavaRDD at <unknown>:0"]; 13943 [labelType="html" label="PythonRDD [13943] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster31174 { label="MicroBatchScan"; 13929 [labelType="html" label="DataSourceRDD [13929] run at <unknown>:0"]; 13930 [labelType="html" label="MapPartitionsRDD [13930] run at <unknown>:0"]; } subgraph cluster31173 { label="Project"; 13931 [labelType="html" label="MapPartitionsRDD [13931] run at <unknown>:0"]; } subgraph cluster31169 { label="WholeStageCodegen (1)"; 13932 [labelType="html" label="MapPartitionsRDD [13932] run at <unknown>:0"]; } subgraph cluster31183 { label="WholeStageCodegen (1)"; 13934 [labelType="html" label="MapPartitionsRDD [13934] toJavaRDD at <unknown>:0"]; } subgraph cluster31182 { label="Filter"; 13935 [labelType="html" label="MapPartitionsRDD [13935] toJavaRDD at <unknown>:0"]; } subgraph cluster31181 { label="Project"; 13936 [labelType="html" label="MapPartitionsRDD [13936] toJavaRDD at <unknown>:0"]; } subgraph cluster31178 { label="WholeStageCodegen (2)"; 13937 [labelType="html" label="MapPartitionsRDD [13937] toJavaRDD at <unknown>:0"]; } subgraph cluster31177 { label="Project"; 13938 [labelType="html" label="MapPartitionsRDD [13938] toJavaRDD at <unknown>:0"]; } subgraph cluster31176 { label="DeserializeToObject"; 13939 [labelType="html" label="MapPartitionsRDD [13939] toJavaRDD at <unknown>:0"]; } subgraph cluster31175 { label="MapPartitions"; 13940 [labelType="html" label="MapPartitionsRDD [13940] toJavaRDD at <unknown>:0"]; } subgraph cluster31185 { label="mapPartitions"; 13942 [labelType="html" label="MapPartitionsRDD [13942] toJavaRDD at <unknown>:0"]; } } 13929->13930; 13930->13931; 13931->13932; 13932->13933; 13933->13934; 13934->13935; 13935->13936; 13936->13937; 13937->13938; 13938->13939; 13939->13940; 13940->13941; 13941->13942; 13942->13943; }

Event Timeline

Enable zooming