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

digraph G { subgraph clusterstage_904 { label="Stage 904"; 9497 [labelType="html" label="SQLExecutionRDD [9497] run at <unknown>:0"]; 9511 [labelType="html" label="SQLExecutionRDD [9511] toJavaRDD at <unknown>:0"]; 9513 [labelType="html" label="PythonRDD [9513] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster21245 { label="MicroBatchScan"; 9493 [labelType="html" label="DataSourceRDD [9493] run at <unknown>:0"]; 9494 [labelType="html" label="MapPartitionsRDD [9494] run at <unknown>:0"]; } subgraph cluster21244 { label="Project"; 9495 [labelType="html" label="MapPartitionsRDD [9495] run at <unknown>:0"]; } subgraph cluster21240 { label="WholeStageCodegen (1)"; 9496 [labelType="html" label="MapPartitionsRDD [9496] run at <unknown>:0"]; } subgraph cluster21262 { label="WholeStageCodegen (1)"; 9504 [labelType="html" label="MapPartitionsRDD [9504] toJavaRDD at <unknown>:0"]; } subgraph cluster21261 { label="Filter"; 9505 [labelType="html" label="MapPartitionsRDD [9505] toJavaRDD at <unknown>:0"]; } subgraph cluster21260 { label="Project"; 9506 [labelType="html" label="MapPartitionsRDD [9506] toJavaRDD at <unknown>:0"]; } subgraph cluster21257 { label="WholeStageCodegen (2)"; 9507 [labelType="html" label="MapPartitionsRDD [9507] toJavaRDD at <unknown>:0"]; } subgraph cluster21256 { label="Project"; 9508 [labelType="html" label="MapPartitionsRDD [9508] toJavaRDD at <unknown>:0"]; } subgraph cluster21255 { label="DeserializeToObject"; 9509 [labelType="html" label="MapPartitionsRDD [9509] toJavaRDD at <unknown>:0"]; } subgraph cluster21254 { label="MapPartitions"; 9510 [labelType="html" label="MapPartitionsRDD [9510] toJavaRDD at <unknown>:0"]; } subgraph cluster21264 { label="mapPartitions"; 9512 [labelType="html" label="MapPartitionsRDD [9512] toJavaRDD at <unknown>:0"]; } } 9493->9494; 9494->9495; 9495->9496; 9496->9497; 9497->9504; 9504->9505; 9505->9506; 9506->9507; 9507->9508; 9508->9509; 9509->9510; 9510->9511; 9511->9512; 9512->9513; }

Event Timeline

Enable zooming