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

digraph G { subgraph clusterstage_1740 { label="Stage 1740"; 18274 [labelType="html" label="SQLExecutionRDD [18274] run at <unknown>:0"]; 18282 [labelType="html" label="SQLExecutionRDD [18282] toJavaRDD at <unknown>:0"]; 18284 [labelType="html" label="PythonRDD [18284] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster40895 { label="MicroBatchScan"; 18270 [labelType="html" label="DataSourceRDD [18270] run at <unknown>:0"]; 18271 [labelType="html" label="MapPartitionsRDD [18271] run at <unknown>:0"]; } subgraph cluster40894 { label="Project"; 18272 [labelType="html" label="MapPartitionsRDD [18272] run at <unknown>:0"]; } subgraph cluster40890 { label="WholeStageCodegen (1)"; 18273 [labelType="html" label="MapPartitionsRDD [18273] run at <unknown>:0"]; } subgraph cluster40904 { label="WholeStageCodegen (1)"; 18275 [labelType="html" label="MapPartitionsRDD [18275] toJavaRDD at <unknown>:0"]; } subgraph cluster40903 { label="Filter"; 18276 [labelType="html" label="MapPartitionsRDD [18276] toJavaRDD at <unknown>:0"]; } subgraph cluster40902 { label="Project"; 18277 [labelType="html" label="MapPartitionsRDD [18277] toJavaRDD at <unknown>:0"]; } subgraph cluster40899 { label="WholeStageCodegen (2)"; 18278 [labelType="html" label="MapPartitionsRDD [18278] toJavaRDD at <unknown>:0"]; } subgraph cluster40898 { label="Project"; 18279 [labelType="html" label="MapPartitionsRDD [18279] toJavaRDD at <unknown>:0"]; } subgraph cluster40897 { label="DeserializeToObject"; 18280 [labelType="html" label="MapPartitionsRDD [18280] toJavaRDD at <unknown>:0"]; } subgraph cluster40896 { label="MapPartitions"; 18281 [labelType="html" label="MapPartitionsRDD [18281] toJavaRDD at <unknown>:0"]; } subgraph cluster40906 { label="mapPartitions"; 18283 [labelType="html" label="MapPartitionsRDD [18283] toJavaRDD at <unknown>:0"]; } } 18270->18271; 18271->18272; 18272->18273; 18273->18274; 18274->18275; 18275->18276; 18276->18277; 18277->18278; 18278->18279; 18279->18280; 18280->18281; 18281->18282; 18282->18283; 18283->18284; }

Event Timeline

Enable zooming