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

digraph G { subgraph clusterstage_1513 { label="Stage 1513"; 15880 [labelType="html" label="SQLExecutionRDD [15880] run at <unknown>:0"]; 15894 [labelType="html" label="SQLExecutionRDD [15894] toJavaRDD at <unknown>:0"]; 15896 [labelType="html" label="PythonRDD [15896] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster35537 { label="MicroBatchScan"; 15876 [labelType="html" label="DataSourceRDD [15876] run at <unknown>:0"]; 15877 [labelType="html" label="MapPartitionsRDD [15877] run at <unknown>:0"]; } subgraph cluster35536 { label="Project"; 15878 [labelType="html" label="MapPartitionsRDD [15878] run at <unknown>:0"]; } subgraph cluster35532 { label="WholeStageCodegen (1)"; 15879 [labelType="html" label="MapPartitionsRDD [15879] run at <unknown>:0"]; } subgraph cluster35554 { label="WholeStageCodegen (1)"; 15887 [labelType="html" label="MapPartitionsRDD [15887] toJavaRDD at <unknown>:0"]; } subgraph cluster35553 { label="Filter"; 15888 [labelType="html" label="MapPartitionsRDD [15888] toJavaRDD at <unknown>:0"]; } subgraph cluster35552 { label="Project"; 15889 [labelType="html" label="MapPartitionsRDD [15889] toJavaRDD at <unknown>:0"]; } subgraph cluster35549 { label="WholeStageCodegen (2)"; 15890 [labelType="html" label="MapPartitionsRDD [15890] toJavaRDD at <unknown>:0"]; } subgraph cluster35548 { label="Project"; 15891 [labelType="html" label="MapPartitionsRDD [15891] toJavaRDD at <unknown>:0"]; } subgraph cluster35547 { label="DeserializeToObject"; 15892 [labelType="html" label="MapPartitionsRDD [15892] toJavaRDD at <unknown>:0"]; } subgraph cluster35546 { label="MapPartitions"; 15893 [labelType="html" label="MapPartitionsRDD [15893] toJavaRDD at <unknown>:0"]; } subgraph cluster35556 { label="mapPartitions"; 15895 [labelType="html" label="MapPartitionsRDD [15895] toJavaRDD at <unknown>:0"]; } } 15876->15877; 15877->15878; 15878->15879; 15879->15880; 15880->15887; 15887->15888; 15888->15889; 15889->15890; 15890->15891; 15891->15892; 15892->15893; 15893->15894; 15894->15895; 15895->15896; }

Event Timeline

Enable zooming