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

digraph G { subgraph clusterstage_1307 { label="Stage 1307"; 13723 [labelType="html" label="SQLExecutionRDD [13723] run at <unknown>:0"]; 13731 [labelType="html" label="SQLExecutionRDD [13731] toJavaRDD at <unknown>:0"]; 13733 [labelType="html" label="PythonRDD [13733] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster30704 { label="MicroBatchScan"; 13719 [labelType="html" label="DataSourceRDD [13719] run at <unknown>:0"]; 13720 [labelType="html" label="MapPartitionsRDD [13720] run at <unknown>:0"]; } subgraph cluster30703 { label="Project"; 13721 [labelType="html" label="MapPartitionsRDD [13721] run at <unknown>:0"]; } subgraph cluster30699 { label="WholeStageCodegen (1)"; 13722 [labelType="html" label="MapPartitionsRDD [13722] run at <unknown>:0"]; } subgraph cluster30713 { label="WholeStageCodegen (1)"; 13724 [labelType="html" label="MapPartitionsRDD [13724] toJavaRDD at <unknown>:0"]; } subgraph cluster30712 { label="Filter"; 13725 [labelType="html" label="MapPartitionsRDD [13725] toJavaRDD at <unknown>:0"]; } subgraph cluster30711 { label="Project"; 13726 [labelType="html" label="MapPartitionsRDD [13726] toJavaRDD at <unknown>:0"]; } subgraph cluster30708 { label="WholeStageCodegen (2)"; 13727 [labelType="html" label="MapPartitionsRDD [13727] toJavaRDD at <unknown>:0"]; } subgraph cluster30707 { label="Project"; 13728 [labelType="html" label="MapPartitionsRDD [13728] toJavaRDD at <unknown>:0"]; } subgraph cluster30706 { label="DeserializeToObject"; 13729 [labelType="html" label="MapPartitionsRDD [13729] toJavaRDD at <unknown>:0"]; } subgraph cluster30705 { label="MapPartitions"; 13730 [labelType="html" label="MapPartitionsRDD [13730] toJavaRDD at <unknown>:0"]; } subgraph cluster30715 { label="mapPartitions"; 13732 [labelType="html" label="MapPartitionsRDD [13732] toJavaRDD at <unknown>:0"]; } } 13719->13720; 13720->13721; 13721->13722; 13722->13723; 13723->13724; 13724->13725; 13725->13726; 13726->13727; 13727->13728; 13728->13729; 13729->13730; 13730->13731; 13731->13732; 13732->13733; }

Event Timeline

Enable zooming