processing-stream-kafka-raw-to-minio - Details for Stage 1799 (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: 1799

digraph G { subgraph clusterstage_1799 { label="Stage 1799"; 18883 [labelType="html" label="SQLExecutionRDD [18883] run at <unknown>:0"]; 18897 [labelType="html" label="SQLExecutionRDD [18897] toJavaRDD at <unknown>:0"]; 18899 [labelType="html" label="PythonRDD [18899] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster42258 { label="MicroBatchScan"; 18879 [labelType="html" label="DataSourceRDD [18879] run at <unknown>:0"]; 18880 [labelType="html" label="MapPartitionsRDD [18880] run at <unknown>:0"]; } subgraph cluster42257 { label="Project"; 18881 [labelType="html" label="MapPartitionsRDD [18881] run at <unknown>:0"]; } subgraph cluster42253 { label="WholeStageCodegen (1)"; 18882 [labelType="html" label="MapPartitionsRDD [18882] run at <unknown>:0"]; } subgraph cluster42275 { label="WholeStageCodegen (1)"; 18890 [labelType="html" label="MapPartitionsRDD [18890] toJavaRDD at <unknown>:0"]; } subgraph cluster42274 { label="Filter"; 18891 [labelType="html" label="MapPartitionsRDD [18891] toJavaRDD at <unknown>:0"]; } subgraph cluster42273 { label="Project"; 18892 [labelType="html" label="MapPartitionsRDD [18892] toJavaRDD at <unknown>:0"]; } subgraph cluster42270 { label="WholeStageCodegen (2)"; 18893 [labelType="html" label="MapPartitionsRDD [18893] toJavaRDD at <unknown>:0"]; } subgraph cluster42269 { label="Project"; 18894 [labelType="html" label="MapPartitionsRDD [18894] toJavaRDD at <unknown>:0"]; } subgraph cluster42268 { label="DeserializeToObject"; 18895 [labelType="html" label="MapPartitionsRDD [18895] toJavaRDD at <unknown>:0"]; } subgraph cluster42267 { label="MapPartitions"; 18896 [labelType="html" label="MapPartitionsRDD [18896] toJavaRDD at <unknown>:0"]; } subgraph cluster42277 { label="mapPartitions"; 18898 [labelType="html" label="MapPartitionsRDD [18898] toJavaRDD at <unknown>:0"]; } } 18879->18880; 18880->18881; 18881->18882; 18882->18883; 18883->18890; 18890->18891; 18891->18892; 18892->18893; 18893->18894; 18894->18895; 18895->18896; 18896->18897; 18897->18898; 18898->18899; }

Event Timeline

Enable zooming