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

digraph G { subgraph clusterstage_2000 { label="Stage 2000"; 21011 [labelType="html" label="SQLExecutionRDD [21011] run at <unknown>:0"]; 21019 [labelType="html" label="SQLExecutionRDD [21019] toJavaRDD at <unknown>:0"]; 21021 [labelType="html" label="PythonRDD [21021] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster47009 { label="MicroBatchScan"; 21007 [labelType="html" label="DataSourceRDD [21007] run at <unknown>:0"]; 21008 [labelType="html" label="MapPartitionsRDD [21008] run at <unknown>:0"]; } subgraph cluster47008 { label="Project"; 21009 [labelType="html" label="MapPartitionsRDD [21009] run at <unknown>:0"]; } subgraph cluster47004 { label="WholeStageCodegen (1)"; 21010 [labelType="html" label="MapPartitionsRDD [21010] run at <unknown>:0"]; } subgraph cluster47018 { label="WholeStageCodegen (1)"; 21012 [labelType="html" label="MapPartitionsRDD [21012] toJavaRDD at <unknown>:0"]; } subgraph cluster47017 { label="Filter"; 21013 [labelType="html" label="MapPartitionsRDD [21013] toJavaRDD at <unknown>:0"]; } subgraph cluster47016 { label="Project"; 21014 [labelType="html" label="MapPartitionsRDD [21014] toJavaRDD at <unknown>:0"]; } subgraph cluster47013 { label="WholeStageCodegen (2)"; 21015 [labelType="html" label="MapPartitionsRDD [21015] toJavaRDD at <unknown>:0"]; } subgraph cluster47012 { label="Project"; 21016 [labelType="html" label="MapPartitionsRDD [21016] toJavaRDD at <unknown>:0"]; } subgraph cluster47011 { label="DeserializeToObject"; 21017 [labelType="html" label="MapPartitionsRDD [21017] toJavaRDD at <unknown>:0"]; } subgraph cluster47010 { label="MapPartitions"; 21018 [labelType="html" label="MapPartitionsRDD [21018] toJavaRDD at <unknown>:0"]; } subgraph cluster47020 { label="mapPartitions"; 21020 [labelType="html" label="MapPartitionsRDD [21020] toJavaRDD at <unknown>:0"]; } } 21007->21008; 21008->21009; 21009->21010; 21010->21011; 21011->21012; 21012->21013; 21013->21014; 21014->21015; 21015->21016; 21016->21017; 21017->21018; 21018->21019; 21019->21020; 21020->21021; }

Event Timeline

Enable zooming