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

digraph G { subgraph clusterstage_1141 { label="Stage 1141"; 11996 [labelType="html" label="SQLExecutionRDD [11996] run at <unknown>:0"]; 12004 [labelType="html" label="SQLExecutionRDD [12004] toJavaRDD at <unknown>:0"]; 12006 [labelType="html" label="PythonRDD [12006] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster26838 { label="MicroBatchScan"; 11992 [labelType="html" label="DataSourceRDD [11992] run at <unknown>:0"]; 11993 [labelType="html" label="MapPartitionsRDD [11993] run at <unknown>:0"]; } subgraph cluster26837 { label="Project"; 11994 [labelType="html" label="MapPartitionsRDD [11994] run at <unknown>:0"]; } subgraph cluster26833 { label="WholeStageCodegen (1)"; 11995 [labelType="html" label="MapPartitionsRDD [11995] run at <unknown>:0"]; } subgraph cluster26847 { label="WholeStageCodegen (1)"; 11997 [labelType="html" label="MapPartitionsRDD [11997] toJavaRDD at <unknown>:0"]; } subgraph cluster26846 { label="Filter"; 11998 [labelType="html" label="MapPartitionsRDD [11998] toJavaRDD at <unknown>:0"]; } subgraph cluster26845 { label="Project"; 11999 [labelType="html" label="MapPartitionsRDD [11999] toJavaRDD at <unknown>:0"]; } subgraph cluster26842 { label="WholeStageCodegen (2)"; 12000 [labelType="html" label="MapPartitionsRDD [12000] toJavaRDD at <unknown>:0"]; } subgraph cluster26841 { label="Project"; 12001 [labelType="html" label="MapPartitionsRDD [12001] toJavaRDD at <unknown>:0"]; } subgraph cluster26840 { label="DeserializeToObject"; 12002 [labelType="html" label="MapPartitionsRDD [12002] toJavaRDD at <unknown>:0"]; } subgraph cluster26839 { label="MapPartitions"; 12003 [labelType="html" label="MapPartitionsRDD [12003] toJavaRDD at <unknown>:0"]; } subgraph cluster26849 { label="mapPartitions"; 12005 [labelType="html" label="MapPartitionsRDD [12005] toJavaRDD at <unknown>:0"]; } } 11992->11993; 11993->11994; 11994->11995; 11995->11996; 11996->11997; 11997->11998; 11998->11999; 11999->12000; 12000->12001; 12001->12002; 12002->12003; 12003->12004; 12004->12005; 12005->12006; }

Event Timeline

Enable zooming