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

digraph G { subgraph clusterstage_1083 { label="Stage 1083"; 11387 [labelType="html" label="SQLExecutionRDD [11387] run at <unknown>:0"]; 11395 [labelType="html" label="SQLExecutionRDD [11395] toJavaRDD at <unknown>:0"]; 11397 [labelType="html" label="PythonRDD [11397] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster25475 { label="MicroBatchScan"; 11383 [labelType="html" label="DataSourceRDD [11383] run at <unknown>:0"]; 11384 [labelType="html" label="MapPartitionsRDD [11384] run at <unknown>:0"]; } subgraph cluster25474 { label="Project"; 11385 [labelType="html" label="MapPartitionsRDD [11385] run at <unknown>:0"]; } subgraph cluster25470 { label="WholeStageCodegen (1)"; 11386 [labelType="html" label="MapPartitionsRDD [11386] run at <unknown>:0"]; } subgraph cluster25484 { label="WholeStageCodegen (1)"; 11388 [labelType="html" label="MapPartitionsRDD [11388] toJavaRDD at <unknown>:0"]; } subgraph cluster25483 { label="Filter"; 11389 [labelType="html" label="MapPartitionsRDD [11389] toJavaRDD at <unknown>:0"]; } subgraph cluster25482 { label="Project"; 11390 [labelType="html" label="MapPartitionsRDD [11390] toJavaRDD at <unknown>:0"]; } subgraph cluster25479 { label="WholeStageCodegen (2)"; 11391 [labelType="html" label="MapPartitionsRDD [11391] toJavaRDD at <unknown>:0"]; } subgraph cluster25478 { label="Project"; 11392 [labelType="html" label="MapPartitionsRDD [11392] toJavaRDD at <unknown>:0"]; } subgraph cluster25477 { label="DeserializeToObject"; 11393 [labelType="html" label="MapPartitionsRDD [11393] toJavaRDD at <unknown>:0"]; } subgraph cluster25476 { label="MapPartitions"; 11394 [labelType="html" label="MapPartitionsRDD [11394] toJavaRDD at <unknown>:0"]; } subgraph cluster25486 { label="mapPartitions"; 11396 [labelType="html" label="MapPartitionsRDD [11396] toJavaRDD at <unknown>:0"]; } } 11383->11384; 11384->11385; 11385->11386; 11386->11387; 11387->11388; 11388->11389; 11389->11390; 11390->11391; 11391->11392; 11392->11393; 11393->11394; 11394->11395; 11395->11396; 11396->11397; }

Event Timeline

Enable zooming