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

digraph G { subgraph clusterstage_604 { label="Stage 604"; 6346 [labelType="html" label="SQLExecutionRDD [6346] run at <unknown>:0"]; 6354 [labelType="html" label="SQLExecutionRDD [6354] toJavaRDD at <unknown>:0"]; 6356 [labelType="html" label="PythonRDD [6356] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster14199 { label="MicroBatchScan"; 6342 [labelType="html" label="DataSourceRDD [6342] run at <unknown>:0"]; 6343 [labelType="html" label="MapPartitionsRDD [6343] run at <unknown>:0"]; } subgraph cluster14198 { label="Project"; 6344 [labelType="html" label="MapPartitionsRDD [6344] run at <unknown>:0"]; } subgraph cluster14194 { label="WholeStageCodegen (1)"; 6345 [labelType="html" label="MapPartitionsRDD [6345] run at <unknown>:0"]; } subgraph cluster14208 { label="WholeStageCodegen (1)"; 6347 [labelType="html" label="MapPartitionsRDD [6347] toJavaRDD at <unknown>:0"]; } subgraph cluster14207 { label="Filter"; 6348 [labelType="html" label="MapPartitionsRDD [6348] toJavaRDD at <unknown>:0"]; } subgraph cluster14206 { label="Project"; 6349 [labelType="html" label="MapPartitionsRDD [6349] toJavaRDD at <unknown>:0"]; } subgraph cluster14203 { label="WholeStageCodegen (2)"; 6350 [labelType="html" label="MapPartitionsRDD [6350] toJavaRDD at <unknown>:0"]; } subgraph cluster14202 { label="Project"; 6351 [labelType="html" label="MapPartitionsRDD [6351] toJavaRDD at <unknown>:0"]; } subgraph cluster14201 { label="DeserializeToObject"; 6352 [labelType="html" label="MapPartitionsRDD [6352] toJavaRDD at <unknown>:0"]; } subgraph cluster14200 { label="MapPartitions"; 6353 [labelType="html" label="MapPartitionsRDD [6353] toJavaRDD at <unknown>:0"]; } subgraph cluster14210 { label="mapPartitions"; 6355 [labelType="html" label="MapPartitionsRDD [6355] toJavaRDD at <unknown>:0"]; } } 6342->6343; 6343->6344; 6344->6345; 6345->6346; 6346->6347; 6347->6348; 6348->6349; 6349->6350; 6350->6351; 6351->6352; 6352->6353; 6353->6354; 6354->6355; 6355->6356; }

Event Timeline

Enable zooming