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

digraph G { subgraph clusterstage_2041 { label="Stage 2041"; 21446 [labelType="html" label="SQLExecutionRDD [21446] run at <unknown>:0"]; 21454 [labelType="html" label="SQLExecutionRDD [21454] toJavaRDD at <unknown>:0"]; 21456 [labelType="html" label="PythonRDD [21456] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster47988 { label="MicroBatchScan"; 21442 [labelType="html" label="DataSourceRDD [21442] run at <unknown>:0"]; 21443 [labelType="html" label="MapPartitionsRDD [21443] run at <unknown>:0"]; } subgraph cluster47987 { label="Project"; 21444 [labelType="html" label="MapPartitionsRDD [21444] run at <unknown>:0"]; } subgraph cluster47983 { label="WholeStageCodegen (1)"; 21445 [labelType="html" label="MapPartitionsRDD [21445] run at <unknown>:0"]; } subgraph cluster47997 { label="WholeStageCodegen (1)"; 21447 [labelType="html" label="MapPartitionsRDD [21447] toJavaRDD at <unknown>:0"]; } subgraph cluster47996 { label="Filter"; 21448 [labelType="html" label="MapPartitionsRDD [21448] toJavaRDD at <unknown>:0"]; } subgraph cluster47995 { label="Project"; 21449 [labelType="html" label="MapPartitionsRDD [21449] toJavaRDD at <unknown>:0"]; } subgraph cluster47992 { label="WholeStageCodegen (2)"; 21450 [labelType="html" label="MapPartitionsRDD [21450] toJavaRDD at <unknown>:0"]; } subgraph cluster47991 { label="Project"; 21451 [labelType="html" label="MapPartitionsRDD [21451] toJavaRDD at <unknown>:0"]; } subgraph cluster47990 { label="DeserializeToObject"; 21452 [labelType="html" label="MapPartitionsRDD [21452] toJavaRDD at <unknown>:0"]; } subgraph cluster47989 { label="MapPartitions"; 21453 [labelType="html" label="MapPartitionsRDD [21453] toJavaRDD at <unknown>:0"]; } subgraph cluster47999 { label="mapPartitions"; 21455 [labelType="html" label="MapPartitionsRDD [21455] toJavaRDD at <unknown>:0"]; } } 21442->21443; 21443->21444; 21444->21445; 21445->21446; 21446->21447; 21447->21448; 21448->21449; 21449->21450; 21450->21451; 21451->21452; 21452->21453; 21453->21454; 21454->21455; 21455->21456; }

Event Timeline

Enable zooming