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

digraph G { subgraph clusterstage_101 { label="Stage 101"; 1054 [labelType="html" label="SQLExecutionRDD [1054] run at <unknown>:0"]; 1068 [labelType="html" label="SQLExecutionRDD [1068] toJavaRDD at <unknown>:0"]; 1070 [labelType="html" label="PythonRDD [1070] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster2355 { label="MicroBatchScan"; 1050 [labelType="html" label="DataSourceRDD [1050] run at <unknown>:0"]; 1051 [labelType="html" label="MapPartitionsRDD [1051] run at <unknown>:0"]; } subgraph cluster2354 { label="Project"; 1052 [labelType="html" label="MapPartitionsRDD [1052] run at <unknown>:0"]; } subgraph cluster2350 { label="WholeStageCodegen (1)"; 1053 [labelType="html" label="MapPartitionsRDD [1053] run at <unknown>:0"]; } subgraph cluster2372 { label="WholeStageCodegen (1)"; 1061 [labelType="html" label="MapPartitionsRDD [1061] toJavaRDD at <unknown>:0"]; } subgraph cluster2371 { label="Filter"; 1062 [labelType="html" label="MapPartitionsRDD [1062] toJavaRDD at <unknown>:0"]; } subgraph cluster2370 { label="Project"; 1063 [labelType="html" label="MapPartitionsRDD [1063] toJavaRDD at <unknown>:0"]; } subgraph cluster2367 { label="WholeStageCodegen (2)"; 1064 [labelType="html" label="MapPartitionsRDD [1064] toJavaRDD at <unknown>:0"]; } subgraph cluster2366 { label="Project"; 1065 [labelType="html" label="MapPartitionsRDD [1065] toJavaRDD at <unknown>:0"]; } subgraph cluster2365 { label="DeserializeToObject"; 1066 [labelType="html" label="MapPartitionsRDD [1066] toJavaRDD at <unknown>:0"]; } subgraph cluster2364 { label="MapPartitions"; 1067 [labelType="html" label="MapPartitionsRDD [1067] toJavaRDD at <unknown>:0"]; } subgraph cluster2374 { label="mapPartitions"; 1069 [labelType="html" label="MapPartitionsRDD [1069] toJavaRDD at <unknown>:0"]; } } 1050->1051; 1051->1052; 1052->1053; 1053->1054; 1054->1061; 1061->1062; 1062->1063; 1063->1064; 1064->1065; 1065->1066; 1066->1067; 1067->1068; 1068->1069; 1069->1070; }

Event Timeline

Enable zooming