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

digraph G { subgraph clusterstage_94 { label="Stage 94"; 991 [labelType="html" label="SQLExecutionRDD [991] run at <unknown>:0"]; 999 [labelType="html" label="SQLExecutionRDD [999] toJavaRDD at <unknown>:0"]; 1001 [labelType="html" label="PythonRDD [1001] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster2214 { label="MicroBatchScan"; 987 [labelType="html" label="DataSourceRDD [987] run at <unknown>:0"]; 988 [labelType="html" label="MapPartitionsRDD [988] run at <unknown>:0"]; } subgraph cluster2213 { label="Project"; 989 [labelType="html" label="MapPartitionsRDD [989] run at <unknown>:0"]; } subgraph cluster2209 { label="WholeStageCodegen (1)"; 990 [labelType="html" label="MapPartitionsRDD [990] run at <unknown>:0"]; } subgraph cluster2223 { label="WholeStageCodegen (1)"; 992 [labelType="html" label="MapPartitionsRDD [992] toJavaRDD at <unknown>:0"]; } subgraph cluster2222 { label="Filter"; 993 [labelType="html" label="MapPartitionsRDD [993] toJavaRDD at <unknown>:0"]; } subgraph cluster2221 { label="Project"; 994 [labelType="html" label="MapPartitionsRDD [994] toJavaRDD at <unknown>:0"]; } subgraph cluster2218 { label="WholeStageCodegen (2)"; 995 [labelType="html" label="MapPartitionsRDD [995] toJavaRDD at <unknown>:0"]; } subgraph cluster2217 { label="Project"; 996 [labelType="html" label="MapPartitionsRDD [996] toJavaRDD at <unknown>:0"]; } subgraph cluster2216 { label="DeserializeToObject"; 997 [labelType="html" label="MapPartitionsRDD [997] toJavaRDD at <unknown>:0"]; } subgraph cluster2215 { label="MapPartitions"; 998 [labelType="html" label="MapPartitionsRDD [998] toJavaRDD at <unknown>:0"]; } subgraph cluster2225 { label="mapPartitions"; 1000 [labelType="html" label="MapPartitionsRDD [1000] toJavaRDD at <unknown>:0"]; } } 987->988; 988->989; 989->990; 990->991; 991->992; 992->993; 993->994; 994->995; 995->996; 996->997; 997->998; 998->999; 999->1000; 1000->1001; }

Event Timeline

Enable zooming