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

digraph G { subgraph clusterstage_1568 { label="Stage 1568"; 16469 [labelType="html" label="SQLExecutionRDD [16469] run at <unknown>:0"]; 16483 [labelType="html" label="SQLExecutionRDD [16483] toJavaRDD at <unknown>:0"]; 16485 [labelType="html" label="PythonRDD [16485] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster36849 { label="MicroBatchScan"; 16465 [labelType="html" label="DataSourceRDD [16465] run at <unknown>:0"]; 16466 [labelType="html" label="MapPartitionsRDD [16466] run at <unknown>:0"]; } subgraph cluster36848 { label="Project"; 16467 [labelType="html" label="MapPartitionsRDD [16467] run at <unknown>:0"]; } subgraph cluster36844 { label="WholeStageCodegen (1)"; 16468 [labelType="html" label="MapPartitionsRDD [16468] run at <unknown>:0"]; } subgraph cluster36864 { label="WholeStageCodegen (1)"; 16471 [labelType="html" label="MapPartitionsRDD [16471] toJavaRDD at <unknown>:0"]; } subgraph cluster36863 { label="Filter"; 16472 [labelType="html" label="MapPartitionsRDD [16472] toJavaRDD at <unknown>:0"]; } subgraph cluster36862 { label="Project"; 16475 [labelType="html" label="MapPartitionsRDD [16475] toJavaRDD at <unknown>:0"]; } subgraph cluster36853 { label="WholeStageCodegen (2)"; 16477 [labelType="html" label="MapPartitionsRDD [16477] toJavaRDD at <unknown>:0"]; } subgraph cluster36852 { label="Project"; 16480 [labelType="html" label="MapPartitionsRDD [16480] toJavaRDD at <unknown>:0"]; } subgraph cluster36851 { label="DeserializeToObject"; 16481 [labelType="html" label="MapPartitionsRDD [16481] toJavaRDD at <unknown>:0"]; } subgraph cluster36850 { label="MapPartitions"; 16482 [labelType="html" label="MapPartitionsRDD [16482] toJavaRDD at <unknown>:0"]; } subgraph cluster36868 { label="mapPartitions"; 16484 [labelType="html" label="MapPartitionsRDD [16484] toJavaRDD at <unknown>:0"]; } } 16465->16466; 16466->16467; 16467->16468; 16468->16469; 16469->16471; 16471->16472; 16472->16475; 16475->16477; 16477->16480; 16480->16481; 16481->16482; 16482->16483; 16483->16484; 16484->16485; }

Event Timeline

Enable zooming