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

digraph G { subgraph clusterstage_1367 { label="Stage 1367"; 14369 [labelType="html" label="SQLExecutionRDD [14369] run at <unknown>:0"]; 14377 [labelType="html" label="SQLExecutionRDD [14377] toJavaRDD at <unknown>:0"]; 14379 [labelType="html" label="PythonRDD [14379] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster32149 { label="MicroBatchScan"; 14365 [labelType="html" label="DataSourceRDD [14365] run at <unknown>:0"]; 14366 [labelType="html" label="MapPartitionsRDD [14366] run at <unknown>:0"]; } subgraph cluster32148 { label="Project"; 14367 [labelType="html" label="MapPartitionsRDD [14367] run at <unknown>:0"]; } subgraph cluster32144 { label="WholeStageCodegen (1)"; 14368 [labelType="html" label="MapPartitionsRDD [14368] run at <unknown>:0"]; } subgraph cluster32158 { label="WholeStageCodegen (1)"; 14370 [labelType="html" label="MapPartitionsRDD [14370] toJavaRDD at <unknown>:0"]; } subgraph cluster32157 { label="Filter"; 14371 [labelType="html" label="MapPartitionsRDD [14371] toJavaRDD at <unknown>:0"]; } subgraph cluster32156 { label="Project"; 14372 [labelType="html" label="MapPartitionsRDD [14372] toJavaRDD at <unknown>:0"]; } subgraph cluster32153 { label="WholeStageCodegen (2)"; 14373 [labelType="html" label="MapPartitionsRDD [14373] toJavaRDD at <unknown>:0"]; } subgraph cluster32152 { label="Project"; 14374 [labelType="html" label="MapPartitionsRDD [14374] toJavaRDD at <unknown>:0"]; } subgraph cluster32151 { label="DeserializeToObject"; 14375 [labelType="html" label="MapPartitionsRDD [14375] toJavaRDD at <unknown>:0"]; } subgraph cluster32150 { label="MapPartitions"; 14376 [labelType="html" label="MapPartitionsRDD [14376] toJavaRDD at <unknown>:0"]; } subgraph cluster32160 { label="mapPartitions"; 14378 [labelType="html" label="MapPartitionsRDD [14378] toJavaRDD at <unknown>:0"]; } } 14365->14366; 14366->14367; 14367->14368; 14368->14369; 14369->14370; 14370->14371; 14371->14372; 14372->14373; 14373->14374; 14374->14375; 14375->14376; 14376->14377; 14377->14378; 14378->14379; }

Event Timeline

Enable zooming