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

digraph G { subgraph clusterstage_2043 { label="Stage 2043"; 21467 [labelType="html" label="SQLExecutionRDD [21467] run at <unknown>:0"]; 21475 [labelType="html" label="SQLExecutionRDD [21475] toJavaRDD at <unknown>:0"]; 21477 [labelType="html" label="PythonRDD [21477] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster48035 { label="MicroBatchScan"; 21463 [labelType="html" label="DataSourceRDD [21463] run at <unknown>:0"]; 21464 [labelType="html" label="MapPartitionsRDD [21464] run at <unknown>:0"]; } subgraph cluster48034 { label="Project"; 21465 [labelType="html" label="MapPartitionsRDD [21465] run at <unknown>:0"]; } subgraph cluster48030 { label="WholeStageCodegen (1)"; 21466 [labelType="html" label="MapPartitionsRDD [21466] run at <unknown>:0"]; } subgraph cluster48044 { label="WholeStageCodegen (1)"; 21468 [labelType="html" label="MapPartitionsRDD [21468] toJavaRDD at <unknown>:0"]; } subgraph cluster48043 { label="Filter"; 21469 [labelType="html" label="MapPartitionsRDD [21469] toJavaRDD at <unknown>:0"]; } subgraph cluster48042 { label="Project"; 21470 [labelType="html" label="MapPartitionsRDD [21470] toJavaRDD at <unknown>:0"]; } subgraph cluster48039 { label="WholeStageCodegen (2)"; 21471 [labelType="html" label="MapPartitionsRDD [21471] toJavaRDD at <unknown>:0"]; } subgraph cluster48038 { label="Project"; 21472 [labelType="html" label="MapPartitionsRDD [21472] toJavaRDD at <unknown>:0"]; } subgraph cluster48037 { label="DeserializeToObject"; 21473 [labelType="html" label="MapPartitionsRDD [21473] toJavaRDD at <unknown>:0"]; } subgraph cluster48036 { label="MapPartitions"; 21474 [labelType="html" label="MapPartitionsRDD [21474] toJavaRDD at <unknown>:0"]; } subgraph cluster48046 { label="mapPartitions"; 21476 [labelType="html" label="MapPartitionsRDD [21476] toJavaRDD at <unknown>:0"]; } } 21463->21464; 21464->21465; 21465->21466; 21466->21467; 21467->21468; 21468->21469; 21469->21470; 21470->21471; 21471->21472; 21472->21473; 21473->21474; 21474->21475; 21475->21476; 21476->21477; }

Event Timeline

Enable zooming