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

digraph G { subgraph clusterstage_999 { label="Stage 999"; 10505 [labelType="html" label="SQLExecutionRDD [10505] run at <unknown>:0"]; 10513 [labelType="html" label="SQLExecutionRDD [10513] toJavaRDD at <unknown>:0"]; 10515 [labelType="html" label="PythonRDD [10515] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster23501 { label="MicroBatchScan"; 10501 [labelType="html" label="DataSourceRDD [10501] run at <unknown>:0"]; 10502 [labelType="html" label="MapPartitionsRDD [10502] run at <unknown>:0"]; } subgraph cluster23500 { label="Project"; 10503 [labelType="html" label="MapPartitionsRDD [10503] run at <unknown>:0"]; } subgraph cluster23496 { label="WholeStageCodegen (1)"; 10504 [labelType="html" label="MapPartitionsRDD [10504] run at <unknown>:0"]; } subgraph cluster23510 { label="WholeStageCodegen (1)"; 10506 [labelType="html" label="MapPartitionsRDD [10506] toJavaRDD at <unknown>:0"]; } subgraph cluster23509 { label="Filter"; 10507 [labelType="html" label="MapPartitionsRDD [10507] toJavaRDD at <unknown>:0"]; } subgraph cluster23508 { label="Project"; 10508 [labelType="html" label="MapPartitionsRDD [10508] toJavaRDD at <unknown>:0"]; } subgraph cluster23505 { label="WholeStageCodegen (2)"; 10509 [labelType="html" label="MapPartitionsRDD [10509] toJavaRDD at <unknown>:0"]; } subgraph cluster23504 { label="Project"; 10510 [labelType="html" label="MapPartitionsRDD [10510] toJavaRDD at <unknown>:0"]; } subgraph cluster23503 { label="DeserializeToObject"; 10511 [labelType="html" label="MapPartitionsRDD [10511] toJavaRDD at <unknown>:0"]; } subgraph cluster23502 { label="MapPartitions"; 10512 [labelType="html" label="MapPartitionsRDD [10512] toJavaRDD at <unknown>:0"]; } subgraph cluster23512 { label="mapPartitions"; 10514 [labelType="html" label="MapPartitionsRDD [10514] toJavaRDD at <unknown>:0"]; } } 10501->10502; 10502->10503; 10503->10504; 10504->10505; 10505->10506; 10506->10507; 10507->10508; 10508->10509; 10509->10510; 10510->10511; 10511->10512; 10512->10513; 10513->10514; 10514->10515; }

Event Timeline

Enable zooming