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

digraph G { subgraph clusterstage_1931 { label="Stage 1931"; 20291 [labelType="html" label="SQLExecutionRDD [20291] run at <unknown>:0"]; 20299 [labelType="html" label="SQLExecutionRDD [20299] toJavaRDD at <unknown>:0"]; 20301 [labelType="html" label="PythonRDD [20301] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster45403 { label="MicroBatchScan"; 20287 [labelType="html" label="DataSourceRDD [20287] run at <unknown>:0"]; 20288 [labelType="html" label="MapPartitionsRDD [20288] run at <unknown>:0"]; } subgraph cluster45402 { label="Project"; 20289 [labelType="html" label="MapPartitionsRDD [20289] run at <unknown>:0"]; } subgraph cluster45398 { label="WholeStageCodegen (1)"; 20290 [labelType="html" label="MapPartitionsRDD [20290] run at <unknown>:0"]; } subgraph cluster45412 { label="WholeStageCodegen (1)"; 20292 [labelType="html" label="MapPartitionsRDD [20292] toJavaRDD at <unknown>:0"]; } subgraph cluster45411 { label="Filter"; 20293 [labelType="html" label="MapPartitionsRDD [20293] toJavaRDD at <unknown>:0"]; } subgraph cluster45410 { label="Project"; 20294 [labelType="html" label="MapPartitionsRDD [20294] toJavaRDD at <unknown>:0"]; } subgraph cluster45407 { label="WholeStageCodegen (2)"; 20295 [labelType="html" label="MapPartitionsRDD [20295] toJavaRDD at <unknown>:0"]; } subgraph cluster45406 { label="Project"; 20296 [labelType="html" label="MapPartitionsRDD [20296] toJavaRDD at <unknown>:0"]; } subgraph cluster45405 { label="DeserializeToObject"; 20297 [labelType="html" label="MapPartitionsRDD [20297] toJavaRDD at <unknown>:0"]; } subgraph cluster45404 { label="MapPartitions"; 20298 [labelType="html" label="MapPartitionsRDD [20298] toJavaRDD at <unknown>:0"]; } subgraph cluster45414 { label="mapPartitions"; 20300 [labelType="html" label="MapPartitionsRDD [20300] toJavaRDD at <unknown>:0"]; } } 20287->20288; 20288->20289; 20289->20290; 20290->20291; 20291->20292; 20292->20293; 20293->20294; 20294->20295; 20295->20296; 20296->20297; 20297->20298; 20298->20299; 20299->20300; 20300->20301; }

Event Timeline

Enable zooming