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

digraph G { subgraph clusterstage_1836 { label="Stage 1836"; 19282 [labelType="html" label="SQLExecutionRDD [19282] run at <unknown>:0"]; 19290 [labelType="html" label="SQLExecutionRDD [19290] toJavaRDD at <unknown>:0"]; 19292 [labelType="html" label="PythonRDD [19292] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster43151 { label="MicroBatchScan"; 19278 [labelType="html" label="DataSourceRDD [19278] run at <unknown>:0"]; 19279 [labelType="html" label="MapPartitionsRDD [19279] run at <unknown>:0"]; } subgraph cluster43150 { label="Project"; 19280 [labelType="html" label="MapPartitionsRDD [19280] run at <unknown>:0"]; } subgraph cluster43146 { label="WholeStageCodegen (1)"; 19281 [labelType="html" label="MapPartitionsRDD [19281] run at <unknown>:0"]; } subgraph cluster43160 { label="WholeStageCodegen (1)"; 19283 [labelType="html" label="MapPartitionsRDD [19283] toJavaRDD at <unknown>:0"]; } subgraph cluster43159 { label="Filter"; 19284 [labelType="html" label="MapPartitionsRDD [19284] toJavaRDD at <unknown>:0"]; } subgraph cluster43158 { label="Project"; 19285 [labelType="html" label="MapPartitionsRDD [19285] toJavaRDD at <unknown>:0"]; } subgraph cluster43155 { label="WholeStageCodegen (2)"; 19286 [labelType="html" label="MapPartitionsRDD [19286] toJavaRDD at <unknown>:0"]; } subgraph cluster43154 { label="Project"; 19287 [labelType="html" label="MapPartitionsRDD [19287] toJavaRDD at <unknown>:0"]; } subgraph cluster43153 { label="DeserializeToObject"; 19288 [labelType="html" label="MapPartitionsRDD [19288] toJavaRDD at <unknown>:0"]; } subgraph cluster43152 { label="MapPartitions"; 19289 [labelType="html" label="MapPartitionsRDD [19289] toJavaRDD at <unknown>:0"]; } subgraph cluster43162 { label="mapPartitions"; 19291 [labelType="html" label="MapPartitionsRDD [19291] toJavaRDD at <unknown>:0"]; } } 19278->19279; 19279->19280; 19280->19281; 19281->19282; 19282->19283; 19283->19284; 19284->19285; 19285->19286; 19286->19287; 19287->19288; 19288->19289; 19289->19290; 19290->19291; 19291->19292; }

Event Timeline

Enable zooming