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

digraph G { subgraph clusterstage_978 { label="Stage 978"; 10273 [labelType="html" label="SQLExecutionRDD [10273] run at <unknown>:0"]; 10281 [labelType="html" label="SQLExecutionRDD [10281] toJavaRDD at <unknown>:0"]; 10283 [labelType="html" label="PythonRDD [10283] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster22988 { label="MicroBatchScan"; 10269 [labelType="html" label="DataSourceRDD [10269] run at <unknown>:0"]; 10270 [labelType="html" label="MapPartitionsRDD [10270] run at <unknown>:0"]; } subgraph cluster22987 { label="Project"; 10271 [labelType="html" label="MapPartitionsRDD [10271] run at <unknown>:0"]; } subgraph cluster22983 { label="WholeStageCodegen (1)"; 10272 [labelType="html" label="MapPartitionsRDD [10272] run at <unknown>:0"]; } subgraph cluster22997 { label="WholeStageCodegen (1)"; 10274 [labelType="html" label="MapPartitionsRDD [10274] toJavaRDD at <unknown>:0"]; } subgraph cluster22996 { label="Filter"; 10275 [labelType="html" label="MapPartitionsRDD [10275] toJavaRDD at <unknown>:0"]; } subgraph cluster22995 { label="Project"; 10276 [labelType="html" label="MapPartitionsRDD [10276] toJavaRDD at <unknown>:0"]; } subgraph cluster22992 { label="WholeStageCodegen (2)"; 10277 [labelType="html" label="MapPartitionsRDD [10277] toJavaRDD at <unknown>:0"]; } subgraph cluster22991 { label="Project"; 10278 [labelType="html" label="MapPartitionsRDD [10278] toJavaRDD at <unknown>:0"]; } subgraph cluster22990 { label="DeserializeToObject"; 10279 [labelType="html" label="MapPartitionsRDD [10279] toJavaRDD at <unknown>:0"]; } subgraph cluster22989 { label="MapPartitions"; 10280 [labelType="html" label="MapPartitionsRDD [10280] toJavaRDD at <unknown>:0"]; } subgraph cluster22999 { label="mapPartitions"; 10282 [labelType="html" label="MapPartitionsRDD [10282] toJavaRDD at <unknown>:0"]; } } 10269->10270; 10270->10271; 10271->10272; 10272->10273; 10273->10274; 10274->10275; 10275->10276; 10276->10277; 10277->10278; 10278->10279; 10279->10280; 10280->10281; 10281->10282; 10282->10283; }

Event Timeline

Enable zooming