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

digraph G { subgraph clusterstage_1463 { label="Stage 1463"; 15355 [labelType="html" label="SQLExecutionRDD [15355] run at <unknown>:0"]; 15369 [labelType="html" label="SQLExecutionRDD [15369] toJavaRDD at <unknown>:0"]; 15371 [labelType="html" label="PythonRDD [15371] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster34362 { label="MicroBatchScan"; 15351 [labelType="html" label="DataSourceRDD [15351] run at <unknown>:0"]; 15352 [labelType="html" label="MapPartitionsRDD [15352] run at <unknown>:0"]; } subgraph cluster34361 { label="Project"; 15353 [labelType="html" label="MapPartitionsRDD [15353] run at <unknown>:0"]; } subgraph cluster34357 { label="WholeStageCodegen (1)"; 15354 [labelType="html" label="MapPartitionsRDD [15354] run at <unknown>:0"]; } subgraph cluster34379 { label="WholeStageCodegen (1)"; 15362 [labelType="html" label="MapPartitionsRDD [15362] toJavaRDD at <unknown>:0"]; } subgraph cluster34378 { label="Filter"; 15363 [labelType="html" label="MapPartitionsRDD [15363] toJavaRDD at <unknown>:0"]; } subgraph cluster34377 { label="Project"; 15364 [labelType="html" label="MapPartitionsRDD [15364] toJavaRDD at <unknown>:0"]; } subgraph cluster34374 { label="WholeStageCodegen (2)"; 15365 [labelType="html" label="MapPartitionsRDD [15365] toJavaRDD at <unknown>:0"]; } subgraph cluster34373 { label="Project"; 15366 [labelType="html" label="MapPartitionsRDD [15366] toJavaRDD at <unknown>:0"]; } subgraph cluster34372 { label="DeserializeToObject"; 15367 [labelType="html" label="MapPartitionsRDD [15367] toJavaRDD at <unknown>:0"]; } subgraph cluster34371 { label="MapPartitions"; 15368 [labelType="html" label="MapPartitionsRDD [15368] toJavaRDD at <unknown>:0"]; } subgraph cluster34381 { label="mapPartitions"; 15370 [labelType="html" label="MapPartitionsRDD [15370] toJavaRDD at <unknown>:0"]; } } 15351->15352; 15352->15353; 15353->15354; 15354->15355; 15355->15362; 15362->15363; 15363->15364; 15364->15365; 15365->15366; 15366->15367; 15367->15368; 15368->15369; 15369->15370; 15370->15371; }

Event Timeline

Enable zooming