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

digraph G { subgraph clusterstage_99 { label="Stage 99"; 1033 [labelType="html" label="SQLExecutionRDD [1033] run at <unknown>:0"]; 1047 [labelType="html" label="SQLExecutionRDD [1047] toJavaRDD at <unknown>:0"]; 1049 [labelType="html" label="PythonRDD [1049] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster2308 { label="MicroBatchScan"; 1029 [labelType="html" label="DataSourceRDD [1029] run at <unknown>:0"]; 1030 [labelType="html" label="MapPartitionsRDD [1030] run at <unknown>:0"]; } subgraph cluster2307 { label="Project"; 1031 [labelType="html" label="MapPartitionsRDD [1031] run at <unknown>:0"]; } subgraph cluster2303 { label="WholeStageCodegen (1)"; 1032 [labelType="html" label="MapPartitionsRDD [1032] run at <unknown>:0"]; } subgraph cluster2325 { label="WholeStageCodegen (1)"; 1040 [labelType="html" label="MapPartitionsRDD [1040] toJavaRDD at <unknown>:0"]; } subgraph cluster2324 { label="Filter"; 1041 [labelType="html" label="MapPartitionsRDD [1041] toJavaRDD at <unknown>:0"]; } subgraph cluster2323 { label="Project"; 1042 [labelType="html" label="MapPartitionsRDD [1042] toJavaRDD at <unknown>:0"]; } subgraph cluster2320 { label="WholeStageCodegen (2)"; 1043 [labelType="html" label="MapPartitionsRDD [1043] toJavaRDD at <unknown>:0"]; } subgraph cluster2319 { label="Project"; 1044 [labelType="html" label="MapPartitionsRDD [1044] toJavaRDD at <unknown>:0"]; } subgraph cluster2318 { label="DeserializeToObject"; 1045 [labelType="html" label="MapPartitionsRDD [1045] toJavaRDD at <unknown>:0"]; } subgraph cluster2317 { label="MapPartitions"; 1046 [labelType="html" label="MapPartitionsRDD [1046] toJavaRDD at <unknown>:0"]; } subgraph cluster2327 { label="mapPartitions"; 1048 [labelType="html" label="MapPartitionsRDD [1048] toJavaRDD at <unknown>:0"]; } } 1029->1030; 1030->1031; 1031->1032; 1032->1033; 1033->1040; 1040->1041; 1041->1042; 1042->1043; 1043->1044; 1044->1045; 1045->1046; 1046->1047; 1047->1048; 1048->1049; }

Event Timeline

Enable zooming