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

digraph G { subgraph clusterstage_547 { label="Stage 547"; 5737 [labelType="html" label="SQLExecutionRDD [5737] run at <unknown>:0"]; 5751 [labelType="html" label="SQLExecutionRDD [5751] toJavaRDD at <unknown>:0"]; 5753 [labelType="html" label="PythonRDD [5753] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster12836 { label="MicroBatchScan"; 5733 [labelType="html" label="DataSourceRDD [5733] run at <unknown>:0"]; 5734 [labelType="html" label="MapPartitionsRDD [5734] run at <unknown>:0"]; } subgraph cluster12835 { label="Project"; 5735 [labelType="html" label="MapPartitionsRDD [5735] run at <unknown>:0"]; } subgraph cluster12831 { label="WholeStageCodegen (1)"; 5736 [labelType="html" label="MapPartitionsRDD [5736] run at <unknown>:0"]; } subgraph cluster12853 { label="WholeStageCodegen (1)"; 5744 [labelType="html" label="MapPartitionsRDD [5744] toJavaRDD at <unknown>:0"]; } subgraph cluster12852 { label="Filter"; 5745 [labelType="html" label="MapPartitionsRDD [5745] toJavaRDD at <unknown>:0"]; } subgraph cluster12851 { label="Project"; 5746 [labelType="html" label="MapPartitionsRDD [5746] toJavaRDD at <unknown>:0"]; } subgraph cluster12848 { label="WholeStageCodegen (2)"; 5747 [labelType="html" label="MapPartitionsRDD [5747] toJavaRDD at <unknown>:0"]; } subgraph cluster12847 { label="Project"; 5748 [labelType="html" label="MapPartitionsRDD [5748] toJavaRDD at <unknown>:0"]; } subgraph cluster12846 { label="DeserializeToObject"; 5749 [labelType="html" label="MapPartitionsRDD [5749] toJavaRDD at <unknown>:0"]; } subgraph cluster12845 { label="MapPartitions"; 5750 [labelType="html" label="MapPartitionsRDD [5750] toJavaRDD at <unknown>:0"]; } subgraph cluster12855 { label="mapPartitions"; 5752 [labelType="html" label="MapPartitionsRDD [5752] toJavaRDD at <unknown>:0"]; } } 5733->5734; 5734->5735; 5735->5736; 5736->5737; 5737->5744; 5744->5745; 5745->5746; 5746->5747; 5747->5748; 5748->5749; 5749->5750; 5750->5751; 5751->5752; 5752->5753; }

Event Timeline

Enable zooming