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

digraph G { subgraph clusterstage_1524 { label="Stage 1524"; 16006 [labelType="html" label="SQLExecutionRDD [16006] run at <unknown>:0"]; 16014 [labelType="html" label="SQLExecutionRDD [16014] toJavaRDD at <unknown>:0"]; 16016 [labelType="html" label="PythonRDD [16016] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster35819 { label="MicroBatchScan"; 16002 [labelType="html" label="DataSourceRDD [16002] run at <unknown>:0"]; 16003 [labelType="html" label="MapPartitionsRDD [16003] run at <unknown>:0"]; } subgraph cluster35818 { label="Project"; 16004 [labelType="html" label="MapPartitionsRDD [16004] run at <unknown>:0"]; } subgraph cluster35814 { label="WholeStageCodegen (1)"; 16005 [labelType="html" label="MapPartitionsRDD [16005] run at <unknown>:0"]; } subgraph cluster35828 { label="WholeStageCodegen (1)"; 16007 [labelType="html" label="MapPartitionsRDD [16007] toJavaRDD at <unknown>:0"]; } subgraph cluster35827 { label="Filter"; 16008 [labelType="html" label="MapPartitionsRDD [16008] toJavaRDD at <unknown>:0"]; } subgraph cluster35826 { label="Project"; 16009 [labelType="html" label="MapPartitionsRDD [16009] toJavaRDD at <unknown>:0"]; } subgraph cluster35823 { label="WholeStageCodegen (2)"; 16010 [labelType="html" label="MapPartitionsRDD [16010] toJavaRDD at <unknown>:0"]; } subgraph cluster35822 { label="Project"; 16011 [labelType="html" label="MapPartitionsRDD [16011] toJavaRDD at <unknown>:0"]; } subgraph cluster35821 { label="DeserializeToObject"; 16012 [labelType="html" label="MapPartitionsRDD [16012] toJavaRDD at <unknown>:0"]; } subgraph cluster35820 { label="MapPartitions"; 16013 [labelType="html" label="MapPartitionsRDD [16013] toJavaRDD at <unknown>:0"]; } subgraph cluster35830 { label="mapPartitions"; 16015 [labelType="html" label="MapPartitionsRDD [16015] toJavaRDD at <unknown>:0"]; } } 16002->16003; 16003->16004; 16004->16005; 16005->16006; 16006->16007; 16007->16008; 16008->16009; 16009->16010; 16010->16011; 16011->16012; 16012->16013; 16013->16014; 16014->16015; 16015->16016; }

Event Timeline

Enable zooming