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

digraph G { subgraph clusterstage_1395 { label="Stage 1395"; 14663 [labelType="html" label="SQLExecutionRDD [14663] run at <unknown>:0"]; 14671 [labelType="html" label="SQLExecutionRDD [14671] toJavaRDD at <unknown>:0"]; 14673 [labelType="html" label="PythonRDD [14673] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster32807 { label="MicroBatchScan"; 14659 [labelType="html" label="DataSourceRDD [14659] run at <unknown>:0"]; 14660 [labelType="html" label="MapPartitionsRDD [14660] run at <unknown>:0"]; } subgraph cluster32806 { label="Project"; 14661 [labelType="html" label="MapPartitionsRDD [14661] run at <unknown>:0"]; } subgraph cluster32802 { label="WholeStageCodegen (1)"; 14662 [labelType="html" label="MapPartitionsRDD [14662] run at <unknown>:0"]; } subgraph cluster32816 { label="WholeStageCodegen (1)"; 14664 [labelType="html" label="MapPartitionsRDD [14664] toJavaRDD at <unknown>:0"]; } subgraph cluster32815 { label="Filter"; 14665 [labelType="html" label="MapPartitionsRDD [14665] toJavaRDD at <unknown>:0"]; } subgraph cluster32814 { label="Project"; 14666 [labelType="html" label="MapPartitionsRDD [14666] toJavaRDD at <unknown>:0"]; } subgraph cluster32811 { label="WholeStageCodegen (2)"; 14667 [labelType="html" label="MapPartitionsRDD [14667] toJavaRDD at <unknown>:0"]; } subgraph cluster32810 { label="Project"; 14668 [labelType="html" label="MapPartitionsRDD [14668] toJavaRDD at <unknown>:0"]; } subgraph cluster32809 { label="DeserializeToObject"; 14669 [labelType="html" label="MapPartitionsRDD [14669] toJavaRDD at <unknown>:0"]; } subgraph cluster32808 { label="MapPartitions"; 14670 [labelType="html" label="MapPartitionsRDD [14670] toJavaRDD at <unknown>:0"]; } subgraph cluster32818 { label="mapPartitions"; 14672 [labelType="html" label="MapPartitionsRDD [14672] toJavaRDD at <unknown>:0"]; } } 14659->14660; 14660->14661; 14661->14662; 14662->14663; 14663->14664; 14664->14665; 14665->14666; 14666->14667; 14667->14668; 14668->14669; 14669->14670; 14670->14671; 14671->14672; 14672->14673; }

Event Timeline

Enable zooming