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

digraph G { subgraph clusterstage_2033 { label="Stage 2033"; 21362 [labelType="html" label="SQLExecutionRDD [21362] run at <unknown>:0"]; 21370 [labelType="html" label="SQLExecutionRDD [21370] toJavaRDD at <unknown>:0"]; 21372 [labelType="html" label="PythonRDD [21372] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster47800 { label="MicroBatchScan"; 21358 [labelType="html" label="DataSourceRDD [21358] run at <unknown>:0"]; 21359 [labelType="html" label="MapPartitionsRDD [21359] run at <unknown>:0"]; } subgraph cluster47799 { label="Project"; 21360 [labelType="html" label="MapPartitionsRDD [21360] run at <unknown>:0"]; } subgraph cluster47795 { label="WholeStageCodegen (1)"; 21361 [labelType="html" label="MapPartitionsRDD [21361] run at <unknown>:0"]; } subgraph cluster47809 { label="WholeStageCodegen (1)"; 21363 [labelType="html" label="MapPartitionsRDD [21363] toJavaRDD at <unknown>:0"]; } subgraph cluster47808 { label="Filter"; 21364 [labelType="html" label="MapPartitionsRDD [21364] toJavaRDD at <unknown>:0"]; } subgraph cluster47807 { label="Project"; 21365 [labelType="html" label="MapPartitionsRDD [21365] toJavaRDD at <unknown>:0"]; } subgraph cluster47804 { label="WholeStageCodegen (2)"; 21366 [labelType="html" label="MapPartitionsRDD [21366] toJavaRDD at <unknown>:0"]; } subgraph cluster47803 { label="Project"; 21367 [labelType="html" label="MapPartitionsRDD [21367] toJavaRDD at <unknown>:0"]; } subgraph cluster47802 { label="DeserializeToObject"; 21368 [labelType="html" label="MapPartitionsRDD [21368] toJavaRDD at <unknown>:0"]; } subgraph cluster47801 { label="MapPartitions"; 21369 [labelType="html" label="MapPartitionsRDD [21369] toJavaRDD at <unknown>:0"]; } subgraph cluster47811 { label="mapPartitions"; 21371 [labelType="html" label="MapPartitionsRDD [21371] toJavaRDD at <unknown>:0"]; } } 21358->21359; 21359->21360; 21360->21361; 21361->21362; 21362->21363; 21363->21364; 21364->21365; 21365->21366; 21366->21367; 21367->21368; 21368->21369; 21369->21370; 21370->21371; 21371->21372; }

Event Timeline

Enable zooming