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

digraph G { subgraph clusterstage_1662 { label="Stage 1662"; 17456 [labelType="html" label="SQLExecutionRDD [17456] run at <unknown>:0"]; 17470 [labelType="html" label="SQLExecutionRDD [17470] toJavaRDD at <unknown>:0"]; 17472 [labelType="html" label="PythonRDD [17472] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster39058 { label="MicroBatchScan"; 17452 [labelType="html" label="DataSourceRDD [17452] run at <unknown>:0"]; 17453 [labelType="html" label="MapPartitionsRDD [17453] run at <unknown>:0"]; } subgraph cluster39057 { label="Project"; 17454 [labelType="html" label="MapPartitionsRDD [17454] run at <unknown>:0"]; } subgraph cluster39053 { label="WholeStageCodegen (1)"; 17455 [labelType="html" label="MapPartitionsRDD [17455] run at <unknown>:0"]; } subgraph cluster39075 { label="WholeStageCodegen (1)"; 17463 [labelType="html" label="MapPartitionsRDD [17463] toJavaRDD at <unknown>:0"]; } subgraph cluster39074 { label="Filter"; 17464 [labelType="html" label="MapPartitionsRDD [17464] toJavaRDD at <unknown>:0"]; } subgraph cluster39073 { label="Project"; 17465 [labelType="html" label="MapPartitionsRDD [17465] toJavaRDD at <unknown>:0"]; } subgraph cluster39070 { label="WholeStageCodegen (2)"; 17466 [labelType="html" label="MapPartitionsRDD [17466] toJavaRDD at <unknown>:0"]; } subgraph cluster39069 { label="Project"; 17467 [labelType="html" label="MapPartitionsRDD [17467] toJavaRDD at <unknown>:0"]; } subgraph cluster39068 { label="DeserializeToObject"; 17468 [labelType="html" label="MapPartitionsRDD [17468] toJavaRDD at <unknown>:0"]; } subgraph cluster39067 { label="MapPartitions"; 17469 [labelType="html" label="MapPartitionsRDD [17469] toJavaRDD at <unknown>:0"]; } subgraph cluster39077 { label="mapPartitions"; 17471 [labelType="html" label="MapPartitionsRDD [17471] toJavaRDD at <unknown>:0"]; } } 17452->17453; 17453->17454; 17454->17455; 17455->17456; 17456->17463; 17463->17464; 17464->17465; 17465->17466; 17466->17467; 17467->17468; 17468->17469; 17469->17470; 17470->17471; 17471->17472; }

Event Timeline

Enable zooming