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

digraph G { subgraph clusterstage_1522 { label="Stage 1522"; 15985 [labelType="html" label="SQLExecutionRDD [15985] run at <unknown>:0"]; 15993 [labelType="html" label="SQLExecutionRDD [15993] toJavaRDD at <unknown>:0"]; 15995 [labelType="html" label="PythonRDD [15995] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster35772 { label="MicroBatchScan"; 15981 [labelType="html" label="DataSourceRDD [15981] run at <unknown>:0"]; 15982 [labelType="html" label="MapPartitionsRDD [15982] run at <unknown>:0"]; } subgraph cluster35771 { label="Project"; 15983 [labelType="html" label="MapPartitionsRDD [15983] run at <unknown>:0"]; } subgraph cluster35767 { label="WholeStageCodegen (1)"; 15984 [labelType="html" label="MapPartitionsRDD [15984] run at <unknown>:0"]; } subgraph cluster35781 { label="WholeStageCodegen (1)"; 15986 [labelType="html" label="MapPartitionsRDD [15986] toJavaRDD at <unknown>:0"]; } subgraph cluster35780 { label="Filter"; 15987 [labelType="html" label="MapPartitionsRDD [15987] toJavaRDD at <unknown>:0"]; } subgraph cluster35779 { label="Project"; 15988 [labelType="html" label="MapPartitionsRDD [15988] toJavaRDD at <unknown>:0"]; } subgraph cluster35776 { label="WholeStageCodegen (2)"; 15989 [labelType="html" label="MapPartitionsRDD [15989] toJavaRDD at <unknown>:0"]; } subgraph cluster35775 { label="Project"; 15990 [labelType="html" label="MapPartitionsRDD [15990] toJavaRDD at <unknown>:0"]; } subgraph cluster35774 { label="DeserializeToObject"; 15991 [labelType="html" label="MapPartitionsRDD [15991] toJavaRDD at <unknown>:0"]; } subgraph cluster35773 { label="MapPartitions"; 15992 [labelType="html" label="MapPartitionsRDD [15992] toJavaRDD at <unknown>:0"]; } subgraph cluster35783 { label="mapPartitions"; 15994 [labelType="html" label="MapPartitionsRDD [15994] toJavaRDD at <unknown>:0"]; } } 15981->15982; 15982->15983; 15983->15984; 15984->15985; 15985->15986; 15986->15987; 15987->15988; 15988->15989; 15989->15990; 15990->15991; 15991->15992; 15992->15993; 15993->15994; 15994->15995; }

Event Timeline

Enable zooming