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

digraph G { subgraph clusterstage_1414 { label="Stage 1414"; 14852 [labelType="html" label="SQLExecutionRDD [14852] run at <unknown>:0"]; 14866 [labelType="html" label="SQLExecutionRDD [14866] toJavaRDD at <unknown>:0"]; 14868 [labelType="html" label="PythonRDD [14868] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster33230 { label="MicroBatchScan"; 14848 [labelType="html" label="DataSourceRDD [14848] run at <unknown>:0"]; 14849 [labelType="html" label="MapPartitionsRDD [14849] run at <unknown>:0"]; } subgraph cluster33229 { label="Project"; 14850 [labelType="html" label="MapPartitionsRDD [14850] run at <unknown>:0"]; } subgraph cluster33225 { label="WholeStageCodegen (1)"; 14851 [labelType="html" label="MapPartitionsRDD [14851] run at <unknown>:0"]; } subgraph cluster33247 { label="WholeStageCodegen (1)"; 14859 [labelType="html" label="MapPartitionsRDD [14859] toJavaRDD at <unknown>:0"]; } subgraph cluster33246 { label="Filter"; 14860 [labelType="html" label="MapPartitionsRDD [14860] toJavaRDD at <unknown>:0"]; } subgraph cluster33245 { label="Project"; 14861 [labelType="html" label="MapPartitionsRDD [14861] toJavaRDD at <unknown>:0"]; } subgraph cluster33242 { label="WholeStageCodegen (2)"; 14862 [labelType="html" label="MapPartitionsRDD [14862] toJavaRDD at <unknown>:0"]; } subgraph cluster33241 { label="Project"; 14863 [labelType="html" label="MapPartitionsRDD [14863] toJavaRDD at <unknown>:0"]; } subgraph cluster33240 { label="DeserializeToObject"; 14864 [labelType="html" label="MapPartitionsRDD [14864] toJavaRDD at <unknown>:0"]; } subgraph cluster33239 { label="MapPartitions"; 14865 [labelType="html" label="MapPartitionsRDD [14865] toJavaRDD at <unknown>:0"]; } subgraph cluster33249 { label="mapPartitions"; 14867 [labelType="html" label="MapPartitionsRDD [14867] toJavaRDD at <unknown>:0"]; } } 14848->14849; 14849->14850; 14850->14851; 14851->14852; 14852->14859; 14859->14860; 14860->14861; 14861->14862; 14862->14863; 14863->14864; 14864->14865; 14865->14866; 14866->14867; 14867->14868; }

Event Timeline

Enable zooming