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

digraph G { subgraph clusterstage_1234 { label="Stage 1234"; 12962 [labelType="html" label="SQLExecutionRDD [12962] run at <unknown>:0"]; 12976 [labelType="html" label="SQLExecutionRDD [12976] toJavaRDD at <unknown>:0"]; 12978 [labelType="html" label="PythonRDD [12978] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster29000 { label="MicroBatchScan"; 12958 [labelType="html" label="DataSourceRDD [12958] run at <unknown>:0"]; 12959 [labelType="html" label="MapPartitionsRDD [12959] run at <unknown>:0"]; } subgraph cluster28999 { label="Project"; 12960 [labelType="html" label="MapPartitionsRDD [12960] run at <unknown>:0"]; } subgraph cluster28995 { label="WholeStageCodegen (1)"; 12961 [labelType="html" label="MapPartitionsRDD [12961] run at <unknown>:0"]; } subgraph cluster29017 { label="WholeStageCodegen (1)"; 12969 [labelType="html" label="MapPartitionsRDD [12969] toJavaRDD at <unknown>:0"]; } subgraph cluster29016 { label="Filter"; 12970 [labelType="html" label="MapPartitionsRDD [12970] toJavaRDD at <unknown>:0"]; } subgraph cluster29015 { label="Project"; 12971 [labelType="html" label="MapPartitionsRDD [12971] toJavaRDD at <unknown>:0"]; } subgraph cluster29012 { label="WholeStageCodegen (2)"; 12972 [labelType="html" label="MapPartitionsRDD [12972] toJavaRDD at <unknown>:0"]; } subgraph cluster29011 { label="Project"; 12973 [labelType="html" label="MapPartitionsRDD [12973] toJavaRDD at <unknown>:0"]; } subgraph cluster29010 { label="DeserializeToObject"; 12974 [labelType="html" label="MapPartitionsRDD [12974] toJavaRDD at <unknown>:0"]; } subgraph cluster29009 { label="MapPartitions"; 12975 [labelType="html" label="MapPartitionsRDD [12975] toJavaRDD at <unknown>:0"]; } subgraph cluster29019 { label="mapPartitions"; 12977 [labelType="html" label="MapPartitionsRDD [12977] toJavaRDD at <unknown>:0"]; } } 12958->12959; 12959->12960; 12960->12961; 12961->12962; 12962->12969; 12969->12970; 12970->12971; 12971->12972; 12972->12973; 12973->12974; 12974->12975; 12975->12976; 12976->12977; 12977->12978; }

Event Timeline

Enable zooming