processing-stream-kafka-raw-to-minio - Details for Stage 1297 (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: 1297

digraph G { subgraph clusterstage_1297 { label="Stage 1297"; 13616 [labelType="html" label="SQLExecutionRDD [13616] run at <unknown>:0"]; 13626 [labelType="html" label="SQLExecutionRDD [13626] toJavaRDD at <unknown>:0"]; 13628 [labelType="html" label="PythonRDD [13628] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster30469 { label="MicroBatchScan"; 13609 [labelType="html" label="DataSourceRDD [13609] run at <unknown>:0"]; 13612 [labelType="html" label="MapPartitionsRDD [13612] run at <unknown>:0"]; } subgraph cluster30468 { label="Project"; 13613 [labelType="html" label="MapPartitionsRDD [13613] run at <unknown>:0"]; } subgraph cluster30462 { label="WholeStageCodegen (1)"; 13614 [labelType="html" label="MapPartitionsRDD [13614] run at <unknown>:0"]; } subgraph cluster30478 { label="WholeStageCodegen (1)"; 13619 [labelType="html" label="MapPartitionsRDD [13619] toJavaRDD at <unknown>:0"]; } subgraph cluster30477 { label="Filter"; 13620 [labelType="html" label="MapPartitionsRDD [13620] toJavaRDD at <unknown>:0"]; } subgraph cluster30476 { label="Project"; 13621 [labelType="html" label="MapPartitionsRDD [13621] toJavaRDD at <unknown>:0"]; } subgraph cluster30473 { label="WholeStageCodegen (2)"; 13622 [labelType="html" label="MapPartitionsRDD [13622] toJavaRDD at <unknown>:0"]; } subgraph cluster30472 { label="Project"; 13623 [labelType="html" label="MapPartitionsRDD [13623] toJavaRDD at <unknown>:0"]; } subgraph cluster30471 { label="DeserializeToObject"; 13624 [labelType="html" label="MapPartitionsRDD [13624] toJavaRDD at <unknown>:0"]; } subgraph cluster30470 { label="MapPartitions"; 13625 [labelType="html" label="MapPartitionsRDD [13625] toJavaRDD at <unknown>:0"]; } subgraph cluster30480 { label="mapPartitions"; 13627 [labelType="html" label="MapPartitionsRDD [13627] toJavaRDD at <unknown>:0"]; } } 13609->13612; 13612->13613; 13613->13614; 13614->13616; 13616->13619; 13619->13620; 13620->13621; 13621->13622; 13622->13623; 13623->13624; 13624->13625; 13625->13626; 13626->13627; 13627->13628; }

Event Timeline

Enable zooming