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

digraph G { subgraph clusterstage_1611 { label="Stage 1611"; 16931 [labelType="html" label="SQLExecutionRDD [16931] run at <unknown>:0"]; 16939 [labelType="html" label="SQLExecutionRDD [16939] toJavaRDD at <unknown>:0"]; 16941 [labelType="html" label="PythonRDD [16941] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster37883 { label="MicroBatchScan"; 16927 [labelType="html" label="DataSourceRDD [16927] run at <unknown>:0"]; 16928 [labelType="html" label="MapPartitionsRDD [16928] run at <unknown>:0"]; } subgraph cluster37882 { label="Project"; 16929 [labelType="html" label="MapPartitionsRDD [16929] run at <unknown>:0"]; } subgraph cluster37878 { label="WholeStageCodegen (1)"; 16930 [labelType="html" label="MapPartitionsRDD [16930] run at <unknown>:0"]; } subgraph cluster37892 { label="WholeStageCodegen (1)"; 16932 [labelType="html" label="MapPartitionsRDD [16932] toJavaRDD at <unknown>:0"]; } subgraph cluster37891 { label="Filter"; 16933 [labelType="html" label="MapPartitionsRDD [16933] toJavaRDD at <unknown>:0"]; } subgraph cluster37890 { label="Project"; 16934 [labelType="html" label="MapPartitionsRDD [16934] toJavaRDD at <unknown>:0"]; } subgraph cluster37887 { label="WholeStageCodegen (2)"; 16935 [labelType="html" label="MapPartitionsRDD [16935] toJavaRDD at <unknown>:0"]; } subgraph cluster37886 { label="Project"; 16936 [labelType="html" label="MapPartitionsRDD [16936] toJavaRDD at <unknown>:0"]; } subgraph cluster37885 { label="DeserializeToObject"; 16937 [labelType="html" label="MapPartitionsRDD [16937] toJavaRDD at <unknown>:0"]; } subgraph cluster37884 { label="MapPartitions"; 16938 [labelType="html" label="MapPartitionsRDD [16938] toJavaRDD at <unknown>:0"]; } subgraph cluster37894 { label="mapPartitions"; 16940 [labelType="html" label="MapPartitionsRDD [16940] toJavaRDD at <unknown>:0"]; } } 16927->16928; 16928->16929; 16929->16930; 16930->16931; 16931->16932; 16932->16933; 16933->16934; 16934->16935; 16935->16936; 16936->16937; 16937->16938; 16938->16939; 16939->16940; 16940->16941; }

Event Timeline

Enable zooming