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

digraph G { subgraph clusterstage_1136 { label="Stage 1136"; 11933 [labelType="html" label="SQLExecutionRDD [11933] run at <unknown>:0"]; 11947 [labelType="html" label="SQLExecutionRDD [11947] toJavaRDD at <unknown>:0"]; 11949 [labelType="html" label="PythonRDD [11949] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster26697 { label="MicroBatchScan"; 11929 [labelType="html" label="DataSourceRDD [11929] run at <unknown>:0"]; 11930 [labelType="html" label="MapPartitionsRDD [11930] run at <unknown>:0"]; } subgraph cluster26696 { label="Project"; 11931 [labelType="html" label="MapPartitionsRDD [11931] run at <unknown>:0"]; } subgraph cluster26692 { label="WholeStageCodegen (1)"; 11932 [labelType="html" label="MapPartitionsRDD [11932] run at <unknown>:0"]; } subgraph cluster26714 { label="WholeStageCodegen (1)"; 11940 [labelType="html" label="MapPartitionsRDD [11940] toJavaRDD at <unknown>:0"]; } subgraph cluster26713 { label="Filter"; 11941 [labelType="html" label="MapPartitionsRDD [11941] toJavaRDD at <unknown>:0"]; } subgraph cluster26712 { label="Project"; 11942 [labelType="html" label="MapPartitionsRDD [11942] toJavaRDD at <unknown>:0"]; } subgraph cluster26709 { label="WholeStageCodegen (2)"; 11943 [labelType="html" label="MapPartitionsRDD [11943] toJavaRDD at <unknown>:0"]; } subgraph cluster26708 { label="Project"; 11944 [labelType="html" label="MapPartitionsRDD [11944] toJavaRDD at <unknown>:0"]; } subgraph cluster26707 { label="DeserializeToObject"; 11945 [labelType="html" label="MapPartitionsRDD [11945] toJavaRDD at <unknown>:0"]; } subgraph cluster26706 { label="MapPartitions"; 11946 [labelType="html" label="MapPartitionsRDD [11946] toJavaRDD at <unknown>:0"]; } subgraph cluster26716 { label="mapPartitions"; 11948 [labelType="html" label="MapPartitionsRDD [11948] toJavaRDD at <unknown>:0"]; } } 11929->11930; 11930->11931; 11931->11932; 11932->11933; 11933->11940; 11940->11941; 11941->11942; 11942->11943; 11943->11944; 11944->11945; 11945->11946; 11946->11947; 11947->11948; 11948->11949; }

Event Timeline

Enable zooming