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

digraph G { subgraph clusterstage_1980 { label="Stage 1980"; 20795 [labelType="html" label="SQLExecutionRDD [20795] run at <unknown>:0"]; 20809 [labelType="html" label="SQLExecutionRDD [20809] toJavaRDD at <unknown>:0"]; 20811 [labelType="html" label="PythonRDD [20811] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster46531 { label="MicroBatchScan"; 20791 [labelType="html" label="DataSourceRDD [20791] run at <unknown>:0"]; 20792 [labelType="html" label="MapPartitionsRDD [20792] run at <unknown>:0"]; } subgraph cluster46530 { label="Project"; 20793 [labelType="html" label="MapPartitionsRDD [20793] run at <unknown>:0"]; } subgraph cluster46526 { label="WholeStageCodegen (1)"; 20794 [labelType="html" label="MapPartitionsRDD [20794] run at <unknown>:0"]; } subgraph cluster46548 { label="WholeStageCodegen (1)"; 20802 [labelType="html" label="MapPartitionsRDD [20802] toJavaRDD at <unknown>:0"]; } subgraph cluster46547 { label="Filter"; 20803 [labelType="html" label="MapPartitionsRDD [20803] toJavaRDD at <unknown>:0"]; } subgraph cluster46546 { label="Project"; 20804 [labelType="html" label="MapPartitionsRDD [20804] toJavaRDD at <unknown>:0"]; } subgraph cluster46543 { label="WholeStageCodegen (2)"; 20805 [labelType="html" label="MapPartitionsRDD [20805] toJavaRDD at <unknown>:0"]; } subgraph cluster46542 { label="Project"; 20806 [labelType="html" label="MapPartitionsRDD [20806] toJavaRDD at <unknown>:0"]; } subgraph cluster46541 { label="DeserializeToObject"; 20807 [labelType="html" label="MapPartitionsRDD [20807] toJavaRDD at <unknown>:0"]; } subgraph cluster46540 { label="MapPartitions"; 20808 [labelType="html" label="MapPartitionsRDD [20808] toJavaRDD at <unknown>:0"]; } subgraph cluster46550 { label="mapPartitions"; 20810 [labelType="html" label="MapPartitionsRDD [20810] toJavaRDD at <unknown>:0"]; } } 20791->20792; 20792->20793; 20793->20794; 20794->20795; 20795->20802; 20802->20803; 20803->20804; 20804->20805; 20805->20806; 20806->20807; 20807->20808; 20808->20809; 20809->20810; 20810->20811; }

Event Timeline

Enable zooming