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

digraph G { subgraph clusterstage_1235 { label="Stage 1235"; 12983 [labelType="html" label="SQLExecutionRDD [12983] run at <unknown>:0"]; 12991 [labelType="html" label="SQLExecutionRDD [12991] toJavaRDD at <unknown>:0"]; 12993 [labelType="html" label="PythonRDD [12993] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster29047 { label="MicroBatchScan"; 12979 [labelType="html" label="DataSourceRDD [12979] run at <unknown>:0"]; 12980 [labelType="html" label="MapPartitionsRDD [12980] run at <unknown>:0"]; } subgraph cluster29046 { label="Project"; 12981 [labelType="html" label="MapPartitionsRDD [12981] run at <unknown>:0"]; } subgraph cluster29042 { label="WholeStageCodegen (1)"; 12982 [labelType="html" label="MapPartitionsRDD [12982] run at <unknown>:0"]; } subgraph cluster29056 { label="WholeStageCodegen (1)"; 12984 [labelType="html" label="MapPartitionsRDD [12984] toJavaRDD at <unknown>:0"]; } subgraph cluster29055 { label="Filter"; 12985 [labelType="html" label="MapPartitionsRDD [12985] toJavaRDD at <unknown>:0"]; } subgraph cluster29054 { label="Project"; 12986 [labelType="html" label="MapPartitionsRDD [12986] toJavaRDD at <unknown>:0"]; } subgraph cluster29051 { label="WholeStageCodegen (2)"; 12987 [labelType="html" label="MapPartitionsRDD [12987] toJavaRDD at <unknown>:0"]; } subgraph cluster29050 { label="Project"; 12988 [labelType="html" label="MapPartitionsRDD [12988] toJavaRDD at <unknown>:0"]; } subgraph cluster29049 { label="DeserializeToObject"; 12989 [labelType="html" label="MapPartitionsRDD [12989] toJavaRDD at <unknown>:0"]; } subgraph cluster29048 { label="MapPartitions"; 12990 [labelType="html" label="MapPartitionsRDD [12990] toJavaRDD at <unknown>:0"]; } subgraph cluster29058 { label="mapPartitions"; 12992 [labelType="html" label="MapPartitionsRDD [12992] toJavaRDD at <unknown>:0"]; } } 12979->12980; 12980->12981; 12981->12982; 12982->12983; 12983->12984; 12984->12985; 12985->12986; 12986->12987; 12987->12988; 12988->12989; 12989->12990; 12990->12991; 12991->12992; 12992->12993; }

Event Timeline

Enable zooming