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

digraph G { subgraph clusterstage_1560 { label="Stage 1560"; 16385 [labelType="html" label="SQLExecutionRDD [16385] run at <unknown>:0"]; 16399 [labelType="html" label="SQLExecutionRDD [16399] toJavaRDD at <unknown>:0"]; 16401 [labelType="html" label="PythonRDD [16401] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster36661 { label="MicroBatchScan"; 16381 [labelType="html" label="DataSourceRDD [16381] run at <unknown>:0"]; 16382 [labelType="html" label="MapPartitionsRDD [16382] run at <unknown>:0"]; } subgraph cluster36660 { label="Project"; 16383 [labelType="html" label="MapPartitionsRDD [16383] run at <unknown>:0"]; } subgraph cluster36656 { label="WholeStageCodegen (1)"; 16384 [labelType="html" label="MapPartitionsRDD [16384] run at <unknown>:0"]; } subgraph cluster36678 { label="WholeStageCodegen (1)"; 16392 [labelType="html" label="MapPartitionsRDD [16392] toJavaRDD at <unknown>:0"]; } subgraph cluster36677 { label="Filter"; 16393 [labelType="html" label="MapPartitionsRDD [16393] toJavaRDD at <unknown>:0"]; } subgraph cluster36676 { label="Project"; 16394 [labelType="html" label="MapPartitionsRDD [16394] toJavaRDD at <unknown>:0"]; } subgraph cluster36673 { label="WholeStageCodegen (2)"; 16395 [labelType="html" label="MapPartitionsRDD [16395] toJavaRDD at <unknown>:0"]; } subgraph cluster36672 { label="Project"; 16396 [labelType="html" label="MapPartitionsRDD [16396] toJavaRDD at <unknown>:0"]; } subgraph cluster36671 { label="DeserializeToObject"; 16397 [labelType="html" label="MapPartitionsRDD [16397] toJavaRDD at <unknown>:0"]; } subgraph cluster36670 { label="MapPartitions"; 16398 [labelType="html" label="MapPartitionsRDD [16398] toJavaRDD at <unknown>:0"]; } subgraph cluster36680 { label="mapPartitions"; 16400 [labelType="html" label="MapPartitionsRDD [16400] toJavaRDD at <unknown>:0"]; } } 16381->16382; 16382->16383; 16383->16384; 16384->16385; 16385->16392; 16392->16393; 16393->16394; 16394->16395; 16395->16396; 16396->16397; 16397->16398; 16398->16399; 16399->16400; 16400->16401; }

Event Timeline

Enable zooming