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

digraph G { subgraph clusterstage_1421 { label="Stage 1421"; 14936 [labelType="html" label="SQLExecutionRDD [14936] run at <unknown>:0"]; 14944 [labelType="html" label="SQLExecutionRDD [14944] toJavaRDD at <unknown>:0"]; 14946 [labelType="html" label="PythonRDD [14946] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster33418 { label="MicroBatchScan"; 14932 [labelType="html" label="DataSourceRDD [14932] run at <unknown>:0"]; 14933 [labelType="html" label="MapPartitionsRDD [14933] run at <unknown>:0"]; } subgraph cluster33417 { label="Project"; 14934 [labelType="html" label="MapPartitionsRDD [14934] run at <unknown>:0"]; } subgraph cluster33413 { label="WholeStageCodegen (1)"; 14935 [labelType="html" label="MapPartitionsRDD [14935] run at <unknown>:0"]; } subgraph cluster33427 { label="WholeStageCodegen (1)"; 14937 [labelType="html" label="MapPartitionsRDD [14937] toJavaRDD at <unknown>:0"]; } subgraph cluster33426 { label="Filter"; 14938 [labelType="html" label="MapPartitionsRDD [14938] toJavaRDD at <unknown>:0"]; } subgraph cluster33425 { label="Project"; 14939 [labelType="html" label="MapPartitionsRDD [14939] toJavaRDD at <unknown>:0"]; } subgraph cluster33422 { label="WholeStageCodegen (2)"; 14940 [labelType="html" label="MapPartitionsRDD [14940] toJavaRDD at <unknown>:0"]; } subgraph cluster33421 { label="Project"; 14941 [labelType="html" label="MapPartitionsRDD [14941] toJavaRDD at <unknown>:0"]; } subgraph cluster33420 { label="DeserializeToObject"; 14942 [labelType="html" label="MapPartitionsRDD [14942] toJavaRDD at <unknown>:0"]; } subgraph cluster33419 { label="MapPartitions"; 14943 [labelType="html" label="MapPartitionsRDD [14943] toJavaRDD at <unknown>:0"]; } subgraph cluster33429 { label="mapPartitions"; 14945 [labelType="html" label="MapPartitionsRDD [14945] toJavaRDD at <unknown>:0"]; } } 14932->14933; 14933->14934; 14934->14935; 14935->14936; 14936->14937; 14937->14938; 14938->14939; 14939->14940; 14940->14941; 14941->14942; 14942->14943; 14943->14944; 14944->14945; 14945->14946; }

Event Timeline

Enable zooming