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

digraph G { subgraph clusterstage_1332 { label="Stage 1332"; 13990 [labelType="html" label="SQLExecutionRDD [13990] run at <unknown>:0"]; 13998 [labelType="html" label="SQLExecutionRDD [13998] toJavaRDD at <unknown>:0"]; 14000 [labelType="html" label="PythonRDD [14000] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster31307 { label="MicroBatchScan"; 13986 [labelType="html" label="DataSourceRDD [13986] run at <unknown>:0"]; 13987 [labelType="html" label="MapPartitionsRDD [13987] run at <unknown>:0"]; } subgraph cluster31306 { label="Project"; 13988 [labelType="html" label="MapPartitionsRDD [13988] run at <unknown>:0"]; } subgraph cluster31302 { label="WholeStageCodegen (1)"; 13989 [labelType="html" label="MapPartitionsRDD [13989] run at <unknown>:0"]; } subgraph cluster31316 { label="WholeStageCodegen (1)"; 13991 [labelType="html" label="MapPartitionsRDD [13991] toJavaRDD at <unknown>:0"]; } subgraph cluster31315 { label="Filter"; 13992 [labelType="html" label="MapPartitionsRDD [13992] toJavaRDD at <unknown>:0"]; } subgraph cluster31314 { label="Project"; 13993 [labelType="html" label="MapPartitionsRDD [13993] toJavaRDD at <unknown>:0"]; } subgraph cluster31311 { label="WholeStageCodegen (2)"; 13994 [labelType="html" label="MapPartitionsRDD [13994] toJavaRDD at <unknown>:0"]; } subgraph cluster31310 { label="Project"; 13995 [labelType="html" label="MapPartitionsRDD [13995] toJavaRDD at <unknown>:0"]; } subgraph cluster31309 { label="DeserializeToObject"; 13996 [labelType="html" label="MapPartitionsRDD [13996] toJavaRDD at <unknown>:0"]; } subgraph cluster31308 { label="MapPartitions"; 13997 [labelType="html" label="MapPartitionsRDD [13997] toJavaRDD at <unknown>:0"]; } subgraph cluster31318 { label="mapPartitions"; 13999 [labelType="html" label="MapPartitionsRDD [13999] toJavaRDD at <unknown>:0"]; } } 13986->13987; 13987->13988; 13988->13989; 13989->13990; 13990->13991; 13991->13992; 13992->13993; 13993->13994; 13994->13995; 13995->13996; 13996->13997; 13997->13998; 13998->13999; 13999->14000; }

Event Timeline

Enable zooming