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

digraph G { subgraph clusterstage_1581 { label="Stage 1581"; 16616 [labelType="html" label="SQLExecutionRDD [16616] run at <unknown>:0"]; 16624 [labelType="html" label="SQLExecutionRDD [16624] toJavaRDD at <unknown>:0"]; 16626 [labelType="html" label="PythonRDD [16626] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster37178 { label="MicroBatchScan"; 16612 [labelType="html" label="DataSourceRDD [16612] run at <unknown>:0"]; 16613 [labelType="html" label="MapPartitionsRDD [16613] run at <unknown>:0"]; } subgraph cluster37177 { label="Project"; 16614 [labelType="html" label="MapPartitionsRDD [16614] run at <unknown>:0"]; } subgraph cluster37173 { label="WholeStageCodegen (1)"; 16615 [labelType="html" label="MapPartitionsRDD [16615] run at <unknown>:0"]; } subgraph cluster37187 { label="WholeStageCodegen (1)"; 16617 [labelType="html" label="MapPartitionsRDD [16617] toJavaRDD at <unknown>:0"]; } subgraph cluster37186 { label="Filter"; 16618 [labelType="html" label="MapPartitionsRDD [16618] toJavaRDD at <unknown>:0"]; } subgraph cluster37185 { label="Project"; 16619 [labelType="html" label="MapPartitionsRDD [16619] toJavaRDD at <unknown>:0"]; } subgraph cluster37182 { label="WholeStageCodegen (2)"; 16620 [labelType="html" label="MapPartitionsRDD [16620] toJavaRDD at <unknown>:0"]; } subgraph cluster37181 { label="Project"; 16621 [labelType="html" label="MapPartitionsRDD [16621] toJavaRDD at <unknown>:0"]; } subgraph cluster37180 { label="DeserializeToObject"; 16622 [labelType="html" label="MapPartitionsRDD [16622] toJavaRDD at <unknown>:0"]; } subgraph cluster37179 { label="MapPartitions"; 16623 [labelType="html" label="MapPartitionsRDD [16623] toJavaRDD at <unknown>:0"]; } subgraph cluster37189 { label="mapPartitions"; 16625 [labelType="html" label="MapPartitionsRDD [16625] toJavaRDD at <unknown>:0"]; } } 16612->16613; 16613->16614; 16614->16615; 16615->16616; 16616->16617; 16617->16618; 16618->16619; 16619->16620; 16620->16621; 16621->16622; 16622->16623; 16623->16624; 16624->16625; 16625->16626; }

Event Timeline

Enable zooming