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

digraph G { subgraph clusterstage_1036 { label="Stage 1036"; 10883 [labelType="html" label="SQLExecutionRDD [10883] run at <unknown>:0"]; 10897 [labelType="html" label="SQLExecutionRDD [10897] toJavaRDD at <unknown>:0"]; 10899 [labelType="html" label="PythonRDD [10899] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster24347 { label="MicroBatchScan"; 10879 [labelType="html" label="DataSourceRDD [10879] run at <unknown>:0"]; 10880 [labelType="html" label="MapPartitionsRDD [10880] run at <unknown>:0"]; } subgraph cluster24346 { label="Project"; 10881 [labelType="html" label="MapPartitionsRDD [10881] run at <unknown>:0"]; } subgraph cluster24342 { label="WholeStageCodegen (1)"; 10882 [labelType="html" label="MapPartitionsRDD [10882] run at <unknown>:0"]; } subgraph cluster24364 { label="WholeStageCodegen (1)"; 10890 [labelType="html" label="MapPartitionsRDD [10890] toJavaRDD at <unknown>:0"]; } subgraph cluster24363 { label="Filter"; 10891 [labelType="html" label="MapPartitionsRDD [10891] toJavaRDD at <unknown>:0"]; } subgraph cluster24362 { label="Project"; 10892 [labelType="html" label="MapPartitionsRDD [10892] toJavaRDD at <unknown>:0"]; } subgraph cluster24359 { label="WholeStageCodegen (2)"; 10893 [labelType="html" label="MapPartitionsRDD [10893] toJavaRDD at <unknown>:0"]; } subgraph cluster24358 { label="Project"; 10894 [labelType="html" label="MapPartitionsRDD [10894] toJavaRDD at <unknown>:0"]; } subgraph cluster24357 { label="DeserializeToObject"; 10895 [labelType="html" label="MapPartitionsRDD [10895] toJavaRDD at <unknown>:0"]; } subgraph cluster24356 { label="MapPartitions"; 10896 [labelType="html" label="MapPartitionsRDD [10896] toJavaRDD at <unknown>:0"]; } subgraph cluster24366 { label="mapPartitions"; 10898 [labelType="html" label="MapPartitionsRDD [10898] toJavaRDD at <unknown>:0"]; } } 10879->10880; 10880->10881; 10881->10882; 10882->10883; 10883->10890; 10890->10891; 10891->10892; 10892->10893; 10893->10894; 10894->10895; 10895->10896; 10896->10897; 10897->10898; 10898->10899; }

Event Timeline

Enable zooming