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

digraph G { subgraph clusterstage_1894 { label="Stage 1894"; 19891 [labelType="html" label="SQLExecutionRDD [19891] run at <unknown>:0"]; 19899 [labelType="html" label="SQLExecutionRDD [19899] toJavaRDD at <unknown>:0"]; 19901 [labelType="html" label="PythonRDD [19901] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster44514 { label="MicroBatchScan"; 19887 [labelType="html" label="DataSourceRDD [19887] run at <unknown>:0"]; 19888 [labelType="html" label="MapPartitionsRDD [19888] run at <unknown>:0"]; } subgraph cluster44513 { label="Project"; 19889 [labelType="html" label="MapPartitionsRDD [19889] run at <unknown>:0"]; } subgraph cluster44509 { label="WholeStageCodegen (1)"; 19890 [labelType="html" label="MapPartitionsRDD [19890] run at <unknown>:0"]; } subgraph cluster44523 { label="WholeStageCodegen (1)"; 19892 [labelType="html" label="MapPartitionsRDD [19892] toJavaRDD at <unknown>:0"]; } subgraph cluster44522 { label="Filter"; 19893 [labelType="html" label="MapPartitionsRDD [19893] toJavaRDD at <unknown>:0"]; } subgraph cluster44521 { label="Project"; 19894 [labelType="html" label="MapPartitionsRDD [19894] toJavaRDD at <unknown>:0"]; } subgraph cluster44518 { label="WholeStageCodegen (2)"; 19895 [labelType="html" label="MapPartitionsRDD [19895] toJavaRDD at <unknown>:0"]; } subgraph cluster44517 { label="Project"; 19896 [labelType="html" label="MapPartitionsRDD [19896] toJavaRDD at <unknown>:0"]; } subgraph cluster44516 { label="DeserializeToObject"; 19897 [labelType="html" label="MapPartitionsRDD [19897] toJavaRDD at <unknown>:0"]; } subgraph cluster44515 { label="MapPartitions"; 19898 [labelType="html" label="MapPartitionsRDD [19898] toJavaRDD at <unknown>:0"]; } subgraph cluster44525 { label="mapPartitions"; 19900 [labelType="html" label="MapPartitionsRDD [19900] toJavaRDD at <unknown>:0"]; } } 19887->19888; 19888->19889; 19889->19890; 19890->19891; 19891->19892; 19892->19893; 19893->19894; 19894->19895; 19895->19896; 19896->19897; 19897->19898; 19898->19899; 19899->19900; 19900->19901; }

Event Timeline

Enable zooming