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

digraph G { subgraph clusterstage_851 { label="Stage 851"; 8929 [labelType="html" label="SQLExecutionRDD [8929] run at <unknown>:0"]; 8943 [labelType="html" label="SQLExecutionRDD [8943] toJavaRDD at <unknown>:0"]; 8945 [labelType="html" label="PythonRDD [8945] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster19980 { label="MicroBatchScan"; 8925 [labelType="html" label="DataSourceRDD [8925] run at <unknown>:0"]; 8926 [labelType="html" label="MapPartitionsRDD [8926] run at <unknown>:0"]; } subgraph cluster19979 { label="Project"; 8927 [labelType="html" label="MapPartitionsRDD [8927] run at <unknown>:0"]; } subgraph cluster19975 { label="WholeStageCodegen (1)"; 8928 [labelType="html" label="MapPartitionsRDD [8928] run at <unknown>:0"]; } subgraph cluster19997 { label="WholeStageCodegen (1)"; 8936 [labelType="html" label="MapPartitionsRDD [8936] toJavaRDD at <unknown>:0"]; } subgraph cluster19996 { label="Filter"; 8937 [labelType="html" label="MapPartitionsRDD [8937] toJavaRDD at <unknown>:0"]; } subgraph cluster19995 { label="Project"; 8938 [labelType="html" label="MapPartitionsRDD [8938] toJavaRDD at <unknown>:0"]; } subgraph cluster19992 { label="WholeStageCodegen (2)"; 8939 [labelType="html" label="MapPartitionsRDD [8939] toJavaRDD at <unknown>:0"]; } subgraph cluster19991 { label="Project"; 8940 [labelType="html" label="MapPartitionsRDD [8940] toJavaRDD at <unknown>:0"]; } subgraph cluster19990 { label="DeserializeToObject"; 8941 [labelType="html" label="MapPartitionsRDD [8941] toJavaRDD at <unknown>:0"]; } subgraph cluster19989 { label="MapPartitions"; 8942 [labelType="html" label="MapPartitionsRDD [8942] toJavaRDD at <unknown>:0"]; } subgraph cluster19999 { label="mapPartitions"; 8944 [labelType="html" label="MapPartitionsRDD [8944] toJavaRDD at <unknown>:0"]; } } 8925->8926; 8926->8927; 8927->8928; 8928->8929; 8929->8936; 8936->8937; 8937->8938; 8938->8939; 8939->8940; 8940->8941; 8941->8942; 8942->8943; 8943->8944; 8944->8945; }

Event Timeline

Enable zooming