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

digraph G { subgraph clusterstage_1465 { label="Stage 1465"; 15382 [labelType="html" label="SQLExecutionRDD [15382] run at <unknown>:0"]; 15390 [labelType="html" label="SQLExecutionRDD [15390] toJavaRDD at <unknown>:0"]; 15392 [labelType="html" label="PythonRDD [15392] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster34417 { label="MicroBatchScan"; 15378 [labelType="html" label="DataSourceRDD [15378] run at <unknown>:0"]; 15379 [labelType="html" label="MapPartitionsRDD [15379] run at <unknown>:0"]; } subgraph cluster34416 { label="Project"; 15380 [labelType="html" label="MapPartitionsRDD [15380] run at <unknown>:0"]; } subgraph cluster34412 { label="WholeStageCodegen (1)"; 15381 [labelType="html" label="MapPartitionsRDD [15381] run at <unknown>:0"]; } subgraph cluster34426 { label="WholeStageCodegen (1)"; 15383 [labelType="html" label="MapPartitionsRDD [15383] toJavaRDD at <unknown>:0"]; } subgraph cluster34425 { label="Filter"; 15384 [labelType="html" label="MapPartitionsRDD [15384] toJavaRDD at <unknown>:0"]; } subgraph cluster34424 { label="Project"; 15385 [labelType="html" label="MapPartitionsRDD [15385] toJavaRDD at <unknown>:0"]; } subgraph cluster34421 { label="WholeStageCodegen (2)"; 15386 [labelType="html" label="MapPartitionsRDD [15386] toJavaRDD at <unknown>:0"]; } subgraph cluster34420 { label="Project"; 15387 [labelType="html" label="MapPartitionsRDD [15387] toJavaRDD at <unknown>:0"]; } subgraph cluster34419 { label="DeserializeToObject"; 15388 [labelType="html" label="MapPartitionsRDD [15388] toJavaRDD at <unknown>:0"]; } subgraph cluster34418 { label="MapPartitions"; 15389 [labelType="html" label="MapPartitionsRDD [15389] toJavaRDD at <unknown>:0"]; } subgraph cluster34428 { label="mapPartitions"; 15391 [labelType="html" label="MapPartitionsRDD [15391] toJavaRDD at <unknown>:0"]; } } 15378->15379; 15379->15380; 15380->15381; 15381->15382; 15382->15383; 15383->15384; 15384->15385; 15385->15386; 15386->15387; 15387->15388; 15388->15389; 15389->15390; 15390->15391; 15391->15392; }

Event Timeline

Enable zooming