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

digraph G { subgraph clusterstage_1130 { label="Stage 1130"; 11870 [labelType="html" label="SQLExecutionRDD [11870] run at <unknown>:0"]; 11884 [labelType="html" label="SQLExecutionRDD [11884] toJavaRDD at <unknown>:0"]; 11886 [labelType="html" label="PythonRDD [11886] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster26556 { label="MicroBatchScan"; 11866 [labelType="html" label="DataSourceRDD [11866] run at <unknown>:0"]; 11867 [labelType="html" label="MapPartitionsRDD [11867] run at <unknown>:0"]; } subgraph cluster26555 { label="Project"; 11868 [labelType="html" label="MapPartitionsRDD [11868] run at <unknown>:0"]; } subgraph cluster26551 { label="WholeStageCodegen (1)"; 11869 [labelType="html" label="MapPartitionsRDD [11869] run at <unknown>:0"]; } subgraph cluster26573 { label="WholeStageCodegen (1)"; 11877 [labelType="html" label="MapPartitionsRDD [11877] toJavaRDD at <unknown>:0"]; } subgraph cluster26572 { label="Filter"; 11878 [labelType="html" label="MapPartitionsRDD [11878] toJavaRDD at <unknown>:0"]; } subgraph cluster26571 { label="Project"; 11879 [labelType="html" label="MapPartitionsRDD [11879] toJavaRDD at <unknown>:0"]; } subgraph cluster26568 { label="WholeStageCodegen (2)"; 11880 [labelType="html" label="MapPartitionsRDD [11880] toJavaRDD at <unknown>:0"]; } subgraph cluster26567 { label="Project"; 11881 [labelType="html" label="MapPartitionsRDD [11881] toJavaRDD at <unknown>:0"]; } subgraph cluster26566 { label="DeserializeToObject"; 11882 [labelType="html" label="MapPartitionsRDD [11882] toJavaRDD at <unknown>:0"]; } subgraph cluster26565 { label="MapPartitions"; 11883 [labelType="html" label="MapPartitionsRDD [11883] toJavaRDD at <unknown>:0"]; } subgraph cluster26575 { label="mapPartitions"; 11885 [labelType="html" label="MapPartitionsRDD [11885] toJavaRDD at <unknown>:0"]; } } 11866->11867; 11867->11868; 11868->11869; 11869->11870; 11870->11877; 11877->11878; 11878->11879; 11879->11880; 11880->11881; 11881->11882; 11882->11883; 11883->11884; 11884->11885; 11885->11886; }

Event Timeline

Enable zooming