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

digraph G { subgraph clusterstage_846 { label="Stage 846"; 8887 [labelType="html" label="SQLExecutionRDD [8887] run at <unknown>:0"]; 8895 [labelType="html" label="SQLExecutionRDD [8895] toJavaRDD at <unknown>:0"]; 8897 [labelType="html" label="PythonRDD [8897] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster19886 { label="MicroBatchScan"; 8883 [labelType="html" label="DataSourceRDD [8883] run at <unknown>:0"]; 8884 [labelType="html" label="MapPartitionsRDD [8884] run at <unknown>:0"]; } subgraph cluster19885 { label="Project"; 8885 [labelType="html" label="MapPartitionsRDD [8885] run at <unknown>:0"]; } subgraph cluster19881 { label="WholeStageCodegen (1)"; 8886 [labelType="html" label="MapPartitionsRDD [8886] run at <unknown>:0"]; } subgraph cluster19895 { label="WholeStageCodegen (1)"; 8888 [labelType="html" label="MapPartitionsRDD [8888] toJavaRDD at <unknown>:0"]; } subgraph cluster19894 { label="Filter"; 8889 [labelType="html" label="MapPartitionsRDD [8889] toJavaRDD at <unknown>:0"]; } subgraph cluster19893 { label="Project"; 8890 [labelType="html" label="MapPartitionsRDD [8890] toJavaRDD at <unknown>:0"]; } subgraph cluster19890 { label="WholeStageCodegen (2)"; 8891 [labelType="html" label="MapPartitionsRDD [8891] toJavaRDD at <unknown>:0"]; } subgraph cluster19889 { label="Project"; 8892 [labelType="html" label="MapPartitionsRDD [8892] toJavaRDD at <unknown>:0"]; } subgraph cluster19888 { label="DeserializeToObject"; 8893 [labelType="html" label="MapPartitionsRDD [8893] toJavaRDD at <unknown>:0"]; } subgraph cluster19887 { label="MapPartitions"; 8894 [labelType="html" label="MapPartitionsRDD [8894] toJavaRDD at <unknown>:0"]; } subgraph cluster19897 { label="mapPartitions"; 8896 [labelType="html" label="MapPartitionsRDD [8896] toJavaRDD at <unknown>:0"]; } } 8883->8884; 8884->8885; 8885->8886; 8886->8887; 8887->8888; 8888->8889; 8889->8890; 8890->8891; 8891->8892; 8892->8893; 8893->8894; 8894->8895; 8895->8896; 8896->8897; }

Event Timeline

Enable zooming