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

digraph G { subgraph clusterstage_857 { label="Stage 857"; 8998 [labelType="html" label="SQLExecutionRDD [8998] run at <unknown>:0"]; 9006 [labelType="html" label="SQLExecutionRDD [9006] toJavaRDD at <unknown>:0"]; 9008 [labelType="html" label="PythonRDD [9008] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster20129 { label="MicroBatchScan"; 8989 [labelType="html" label="DataSourceRDD [8989] run at <unknown>:0"]; 8991 [labelType="html" label="MapPartitionsRDD [8991] run at <unknown>:0"]; } subgraph cluster20128 { label="Project"; 8993 [labelType="html" label="MapPartitionsRDD [8993] run at <unknown>:0"]; } subgraph cluster20122 { label="WholeStageCodegen (1)"; 8996 [labelType="html" label="MapPartitionsRDD [8996] run at <unknown>:0"]; } subgraph cluster20138 { label="WholeStageCodegen (1)"; 8999 [labelType="html" label="MapPartitionsRDD [8999] toJavaRDD at <unknown>:0"]; } subgraph cluster20137 { label="Filter"; 9000 [labelType="html" label="MapPartitionsRDD [9000] toJavaRDD at <unknown>:0"]; } subgraph cluster20136 { label="Project"; 9001 [labelType="html" label="MapPartitionsRDD [9001] toJavaRDD at <unknown>:0"]; } subgraph cluster20133 { label="WholeStageCodegen (2)"; 9002 [labelType="html" label="MapPartitionsRDD [9002] toJavaRDD at <unknown>:0"]; } subgraph cluster20132 { label="Project"; 9003 [labelType="html" label="MapPartitionsRDD [9003] toJavaRDD at <unknown>:0"]; } subgraph cluster20131 { label="DeserializeToObject"; 9004 [labelType="html" label="MapPartitionsRDD [9004] toJavaRDD at <unknown>:0"]; } subgraph cluster20130 { label="MapPartitions"; 9005 [labelType="html" label="MapPartitionsRDD [9005] toJavaRDD at <unknown>:0"]; } subgraph cluster20140 { label="mapPartitions"; 9007 [labelType="html" label="MapPartitionsRDD [9007] toJavaRDD at <unknown>:0"]; } } 8989->8991; 8991->8993; 8993->8996; 8996->8998; 8998->8999; 8999->9000; 9000->9001; 9001->9002; 9002->9003; 9003->9004; 9004->9005; 9005->9006; 9006->9007; 9007->9008; }

Event Timeline

Enable zooming