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

digraph G { subgraph clusterstage_1265 { label="Stage 1265"; 13276 [labelType="html" label="SQLExecutionRDD [13276] run at <unknown>:0"]; 13290 [labelType="html" label="SQLExecutionRDD [13290] toJavaRDD at <unknown>:0"]; 13292 [labelType="html" label="PythonRDD [13292] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster29709 { label="MicroBatchScan"; 13272 [labelType="html" label="DataSourceRDD [13272] run at <unknown>:0"]; 13273 [labelType="html" label="MapPartitionsRDD [13273] run at <unknown>:0"]; } subgraph cluster29708 { label="Project"; 13274 [labelType="html" label="MapPartitionsRDD [13274] run at <unknown>:0"]; } subgraph cluster29704 { label="WholeStageCodegen (1)"; 13275 [labelType="html" label="MapPartitionsRDD [13275] run at <unknown>:0"]; } subgraph cluster29726 { label="WholeStageCodegen (1)"; 13283 [labelType="html" label="MapPartitionsRDD [13283] toJavaRDD at <unknown>:0"]; } subgraph cluster29725 { label="Filter"; 13284 [labelType="html" label="MapPartitionsRDD [13284] toJavaRDD at <unknown>:0"]; } subgraph cluster29724 { label="Project"; 13285 [labelType="html" label="MapPartitionsRDD [13285] toJavaRDD at <unknown>:0"]; } subgraph cluster29721 { label="WholeStageCodegen (2)"; 13286 [labelType="html" label="MapPartitionsRDD [13286] toJavaRDD at <unknown>:0"]; } subgraph cluster29720 { label="Project"; 13287 [labelType="html" label="MapPartitionsRDD [13287] toJavaRDD at <unknown>:0"]; } subgraph cluster29719 { label="DeserializeToObject"; 13288 [labelType="html" label="MapPartitionsRDD [13288] toJavaRDD at <unknown>:0"]; } subgraph cluster29718 { label="MapPartitions"; 13289 [labelType="html" label="MapPartitionsRDD [13289] toJavaRDD at <unknown>:0"]; } subgraph cluster29728 { label="mapPartitions"; 13291 [labelType="html" label="MapPartitionsRDD [13291] toJavaRDD at <unknown>:0"]; } } 13272->13273; 13273->13274; 13274->13275; 13275->13276; 13276->13283; 13283->13284; 13284->13285; 13285->13286; 13286->13287; 13287->13288; 13288->13289; 13289->13290; 13290->13291; 13291->13292; }

Event Timeline

Enable zooming