processing-stream-kafka-raw-to-minio - Details for Stage 1809 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 4
Input Size / Records: 0.0 B / 461
Associated Job Ids: 1809

digraph G { subgraph clusterstage_1809 { label="Stage 1809"; 18994 [labelType="html" label="SQLExecutionRDD [18994] run at <unknown>:0"]; 19002 [labelType="html" label="SQLExecutionRDD [19002] toJavaRDD at <unknown>:0"]; 19004 [labelType="html" label="PythonRDD [19004] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster42501 { label="MicroBatchScan"; 18990 [labelType="html" label="DataSourceRDD [18990] run at <unknown>:0"]; 18991 [labelType="html" label="MapPartitionsRDD [18991] run at <unknown>:0"]; } subgraph cluster42500 { label="Project"; 18992 [labelType="html" label="MapPartitionsRDD [18992] run at <unknown>:0"]; } subgraph cluster42496 { label="WholeStageCodegen (1)"; 18993 [labelType="html" label="MapPartitionsRDD [18993] run at <unknown>:0"]; } subgraph cluster42510 { label="WholeStageCodegen (1)"; 18995 [labelType="html" label="MapPartitionsRDD [18995] toJavaRDD at <unknown>:0"]; } subgraph cluster42509 { label="Filter"; 18996 [labelType="html" label="MapPartitionsRDD [18996] toJavaRDD at <unknown>:0"]; } subgraph cluster42508 { label="Project"; 18997 [labelType="html" label="MapPartitionsRDD [18997] toJavaRDD at <unknown>:0"]; } subgraph cluster42505 { label="WholeStageCodegen (2)"; 18998 [labelType="html" label="MapPartitionsRDD [18998] toJavaRDD at <unknown>:0"]; } subgraph cluster42504 { label="Project"; 18999 [labelType="html" label="MapPartitionsRDD [18999] toJavaRDD at <unknown>:0"]; } subgraph cluster42503 { label="DeserializeToObject"; 19000 [labelType="html" label="MapPartitionsRDD [19000] toJavaRDD at <unknown>:0"]; } subgraph cluster42502 { label="MapPartitions"; 19001 [labelType="html" label="MapPartitionsRDD [19001] toJavaRDD at <unknown>:0"]; } subgraph cluster42512 { label="mapPartitions"; 19003 [labelType="html" label="MapPartitionsRDD [19003] toJavaRDD at <unknown>:0"]; } } 18990->18991; 18991->18992; 18992->18993; 18993->18994; 18994->18995; 18995->18996; 18996->18997; 18997->18998; 18998->18999; 18999->19000; 19000->19001; 19001->19002; 19002->19003; 19003->19004; }

Event Timeline

Enable zooming