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

digraph G { subgraph clusterstage_1573 { label="Stage 1573"; 16532 [labelType="html" label="SQLExecutionRDD [16532] run at <unknown>:0"]; 16540 [labelType="html" label="SQLExecutionRDD [16540] toJavaRDD at <unknown>:0"]; 16542 [labelType="html" label="PythonRDD [16542] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster36990 { label="MicroBatchScan"; 16528 [labelType="html" label="DataSourceRDD [16528] run at <unknown>:0"]; 16529 [labelType="html" label="MapPartitionsRDD [16529] run at <unknown>:0"]; } subgraph cluster36989 { label="Project"; 16530 [labelType="html" label="MapPartitionsRDD [16530] run at <unknown>:0"]; } subgraph cluster36985 { label="WholeStageCodegen (1)"; 16531 [labelType="html" label="MapPartitionsRDD [16531] run at <unknown>:0"]; } subgraph cluster36999 { label="WholeStageCodegen (1)"; 16533 [labelType="html" label="MapPartitionsRDD [16533] toJavaRDD at <unknown>:0"]; } subgraph cluster36998 { label="Filter"; 16534 [labelType="html" label="MapPartitionsRDD [16534] toJavaRDD at <unknown>:0"]; } subgraph cluster36997 { label="Project"; 16535 [labelType="html" label="MapPartitionsRDD [16535] toJavaRDD at <unknown>:0"]; } subgraph cluster36994 { label="WholeStageCodegen (2)"; 16536 [labelType="html" label="MapPartitionsRDD [16536] toJavaRDD at <unknown>:0"]; } subgraph cluster36993 { label="Project"; 16537 [labelType="html" label="MapPartitionsRDD [16537] toJavaRDD at <unknown>:0"]; } subgraph cluster36992 { label="DeserializeToObject"; 16538 [labelType="html" label="MapPartitionsRDD [16538] toJavaRDD at <unknown>:0"]; } subgraph cluster36991 { label="MapPartitions"; 16539 [labelType="html" label="MapPartitionsRDD [16539] toJavaRDD at <unknown>:0"]; } subgraph cluster37001 { label="mapPartitions"; 16541 [labelType="html" label="MapPartitionsRDD [16541] toJavaRDD at <unknown>:0"]; } } 16528->16529; 16529->16530; 16530->16531; 16531->16532; 16532->16533; 16533->16534; 16534->16535; 16535->16536; 16536->16537; 16537->16538; 16538->16539; 16539->16540; 16540->16541; 16541->16542; }

Event Timeline

Enable zooming