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

digraph G { subgraph clusterstage_500 { label="Stage 500"; 5254 [labelType="html" label="SQLExecutionRDD [5254] run at <unknown>:0"]; 5262 [labelType="html" label="SQLExecutionRDD [5262] toJavaRDD at <unknown>:0"]; 5264 [labelType="html" label="PythonRDD [5264] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster11755 { label="MicroBatchScan"; 5250 [labelType="html" label="DataSourceRDD [5250] run at <unknown>:0"]; 5251 [labelType="html" label="MapPartitionsRDD [5251] run at <unknown>:0"]; } subgraph cluster11754 { label="Project"; 5252 [labelType="html" label="MapPartitionsRDD [5252] run at <unknown>:0"]; } subgraph cluster11750 { label="WholeStageCodegen (1)"; 5253 [labelType="html" label="MapPartitionsRDD [5253] run at <unknown>:0"]; } subgraph cluster11764 { label="WholeStageCodegen (1)"; 5255 [labelType="html" label="MapPartitionsRDD [5255] toJavaRDD at <unknown>:0"]; } subgraph cluster11763 { label="Filter"; 5256 [labelType="html" label="MapPartitionsRDD [5256] toJavaRDD at <unknown>:0"]; } subgraph cluster11762 { label="Project"; 5257 [labelType="html" label="MapPartitionsRDD [5257] toJavaRDD at <unknown>:0"]; } subgraph cluster11759 { label="WholeStageCodegen (2)"; 5258 [labelType="html" label="MapPartitionsRDD [5258] toJavaRDD at <unknown>:0"]; } subgraph cluster11758 { label="Project"; 5259 [labelType="html" label="MapPartitionsRDD [5259] toJavaRDD at <unknown>:0"]; } subgraph cluster11757 { label="DeserializeToObject"; 5260 [labelType="html" label="MapPartitionsRDD [5260] toJavaRDD at <unknown>:0"]; } subgraph cluster11756 { label="MapPartitions"; 5261 [labelType="html" label="MapPartitionsRDD [5261] toJavaRDD at <unknown>:0"]; } subgraph cluster11766 { label="mapPartitions"; 5263 [labelType="html" label="MapPartitionsRDD [5263] toJavaRDD at <unknown>:0"]; } } 5250->5251; 5251->5252; 5252->5253; 5253->5254; 5254->5255; 5255->5256; 5256->5257; 5257->5258; 5258->5259; 5259->5260; 5260->5261; 5261->5262; 5262->5263; 5263->5264; }

Event Timeline

Enable zooming