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

digraph G { subgraph clusterstage_762 { label="Stage 762"; 8005 [labelType="html" label="SQLExecutionRDD [8005] run at <unknown>:0"]; 8013 [labelType="html" label="SQLExecutionRDD [8013] toJavaRDD at <unknown>:0"]; 8015 [labelType="html" label="PythonRDD [8015] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster17912 { label="MicroBatchScan"; 8001 [labelType="html" label="DataSourceRDD [8001] run at <unknown>:0"]; 8002 [labelType="html" label="MapPartitionsRDD [8002] run at <unknown>:0"]; } subgraph cluster17911 { label="Project"; 8003 [labelType="html" label="MapPartitionsRDD [8003] run at <unknown>:0"]; } subgraph cluster17907 { label="WholeStageCodegen (1)"; 8004 [labelType="html" label="MapPartitionsRDD [8004] run at <unknown>:0"]; } subgraph cluster17921 { label="WholeStageCodegen (1)"; 8006 [labelType="html" label="MapPartitionsRDD [8006] toJavaRDD at <unknown>:0"]; } subgraph cluster17920 { label="Filter"; 8007 [labelType="html" label="MapPartitionsRDD [8007] toJavaRDD at <unknown>:0"]; } subgraph cluster17919 { label="Project"; 8008 [labelType="html" label="MapPartitionsRDD [8008] toJavaRDD at <unknown>:0"]; } subgraph cluster17916 { label="WholeStageCodegen (2)"; 8009 [labelType="html" label="MapPartitionsRDD [8009] toJavaRDD at <unknown>:0"]; } subgraph cluster17915 { label="Project"; 8010 [labelType="html" label="MapPartitionsRDD [8010] toJavaRDD at <unknown>:0"]; } subgraph cluster17914 { label="DeserializeToObject"; 8011 [labelType="html" label="MapPartitionsRDD [8011] toJavaRDD at <unknown>:0"]; } subgraph cluster17913 { label="MapPartitions"; 8012 [labelType="html" label="MapPartitionsRDD [8012] toJavaRDD at <unknown>:0"]; } subgraph cluster17923 { label="mapPartitions"; 8014 [labelType="html" label="MapPartitionsRDD [8014] toJavaRDD at <unknown>:0"]; } } 8001->8002; 8002->8003; 8003->8004; 8004->8005; 8005->8006; 8006->8007; 8007->8008; 8008->8009; 8009->8010; 8010->8011; 8011->8012; 8012->8013; 8013->8014; 8014->8015; }

Event Timeline

Enable zooming