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

digraph G { subgraph clusterstage_1518 { label="Stage 1518"; 15943 [labelType="html" label="SQLExecutionRDD [15943] run at <unknown>:0"]; 15951 [labelType="html" label="SQLExecutionRDD [15951] toJavaRDD at <unknown>:0"]; 15953 [labelType="html" label="PythonRDD [15953] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster35678 { label="MicroBatchScan"; 15939 [labelType="html" label="DataSourceRDD [15939] run at <unknown>:0"]; 15940 [labelType="html" label="MapPartitionsRDD [15940] run at <unknown>:0"]; } subgraph cluster35677 { label="Project"; 15941 [labelType="html" label="MapPartitionsRDD [15941] run at <unknown>:0"]; } subgraph cluster35673 { label="WholeStageCodegen (1)"; 15942 [labelType="html" label="MapPartitionsRDD [15942] run at <unknown>:0"]; } subgraph cluster35687 { label="WholeStageCodegen (1)"; 15944 [labelType="html" label="MapPartitionsRDD [15944] toJavaRDD at <unknown>:0"]; } subgraph cluster35686 { label="Filter"; 15945 [labelType="html" label="MapPartitionsRDD [15945] toJavaRDD at <unknown>:0"]; } subgraph cluster35685 { label="Project"; 15946 [labelType="html" label="MapPartitionsRDD [15946] toJavaRDD at <unknown>:0"]; } subgraph cluster35682 { label="WholeStageCodegen (2)"; 15947 [labelType="html" label="MapPartitionsRDD [15947] toJavaRDD at <unknown>:0"]; } subgraph cluster35681 { label="Project"; 15948 [labelType="html" label="MapPartitionsRDD [15948] toJavaRDD at <unknown>:0"]; } subgraph cluster35680 { label="DeserializeToObject"; 15949 [labelType="html" label="MapPartitionsRDD [15949] toJavaRDD at <unknown>:0"]; } subgraph cluster35679 { label="MapPartitions"; 15950 [labelType="html" label="MapPartitionsRDD [15950] toJavaRDD at <unknown>:0"]; } subgraph cluster35689 { label="mapPartitions"; 15952 [labelType="html" label="MapPartitionsRDD [15952] toJavaRDD at <unknown>:0"]; } } 15939->15940; 15940->15941; 15941->15942; 15942->15943; 15943->15944; 15944->15945; 15945->15946; 15946->15947; 15947->15948; 15948->15949; 15949->15950; 15950->15951; 15951->15952; 15952->15953; }

Event Timeline

Enable zooming