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

digraph G { subgraph clusterstage_1531 { label="Stage 1531"; 16075 [labelType="html" label="SQLExecutionRDD [16075] run at <unknown>:0"]; 16083 [labelType="html" label="SQLExecutionRDD [16083] toJavaRDD at <unknown>:0"]; 16085 [labelType="html" label="PythonRDD [16085] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster35968 { label="MicroBatchScan"; 16071 [labelType="html" label="DataSourceRDD [16071] run at <unknown>:0"]; 16072 [labelType="html" label="MapPartitionsRDD [16072] run at <unknown>:0"]; } subgraph cluster35967 { label="Project"; 16073 [labelType="html" label="MapPartitionsRDD [16073] run at <unknown>:0"]; } subgraph cluster35963 { label="WholeStageCodegen (1)"; 16074 [labelType="html" label="MapPartitionsRDD [16074] run at <unknown>:0"]; } subgraph cluster35977 { label="WholeStageCodegen (1)"; 16076 [labelType="html" label="MapPartitionsRDD [16076] toJavaRDD at <unknown>:0"]; } subgraph cluster35976 { label="Filter"; 16077 [labelType="html" label="MapPartitionsRDD [16077] toJavaRDD at <unknown>:0"]; } subgraph cluster35975 { label="Project"; 16078 [labelType="html" label="MapPartitionsRDD [16078] toJavaRDD at <unknown>:0"]; } subgraph cluster35972 { label="WholeStageCodegen (2)"; 16079 [labelType="html" label="MapPartitionsRDD [16079] toJavaRDD at <unknown>:0"]; } subgraph cluster35971 { label="Project"; 16080 [labelType="html" label="MapPartitionsRDD [16080] toJavaRDD at <unknown>:0"]; } subgraph cluster35970 { label="DeserializeToObject"; 16081 [labelType="html" label="MapPartitionsRDD [16081] toJavaRDD at <unknown>:0"]; } subgraph cluster35969 { label="MapPartitions"; 16082 [labelType="html" label="MapPartitionsRDD [16082] toJavaRDD at <unknown>:0"]; } subgraph cluster35979 { label="mapPartitions"; 16084 [labelType="html" label="MapPartitionsRDD [16084] toJavaRDD at <unknown>:0"]; } } 16071->16072; 16072->16073; 16073->16074; 16074->16075; 16075->16076; 16076->16077; 16077->16078; 16078->16079; 16079->16080; 16080->16081; 16081->16082; 16082->16083; 16083->16084; 16084->16085; }

Event Timeline

Enable zooming