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

digraph G { subgraph clusterstage_105 { label="Stage 105"; 1096 [labelType="html" label="SQLExecutionRDD [1096] run at <unknown>:0"]; 1110 [labelType="html" label="SQLExecutionRDD [1110] toJavaRDD at <unknown>:0"]; 1112 [labelType="html" label="PythonRDD [1112] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster2449 { label="MicroBatchScan"; 1092 [labelType="html" label="DataSourceRDD [1092] run at <unknown>:0"]; 1093 [labelType="html" label="MapPartitionsRDD [1093] run at <unknown>:0"]; } subgraph cluster2448 { label="Project"; 1094 [labelType="html" label="MapPartitionsRDD [1094] run at <unknown>:0"]; } subgraph cluster2444 { label="WholeStageCodegen (1)"; 1095 [labelType="html" label="MapPartitionsRDD [1095] run at <unknown>:0"]; } subgraph cluster2466 { label="WholeStageCodegen (1)"; 1103 [labelType="html" label="MapPartitionsRDD [1103] toJavaRDD at <unknown>:0"]; } subgraph cluster2465 { label="Filter"; 1104 [labelType="html" label="MapPartitionsRDD [1104] toJavaRDD at <unknown>:0"]; } subgraph cluster2464 { label="Project"; 1105 [labelType="html" label="MapPartitionsRDD [1105] toJavaRDD at <unknown>:0"]; } subgraph cluster2461 { label="WholeStageCodegen (2)"; 1106 [labelType="html" label="MapPartitionsRDD [1106] toJavaRDD at <unknown>:0"]; } subgraph cluster2460 { label="Project"; 1107 [labelType="html" label="MapPartitionsRDD [1107] toJavaRDD at <unknown>:0"]; } subgraph cluster2459 { label="DeserializeToObject"; 1108 [labelType="html" label="MapPartitionsRDD [1108] toJavaRDD at <unknown>:0"]; } subgraph cluster2458 { label="MapPartitions"; 1109 [labelType="html" label="MapPartitionsRDD [1109] toJavaRDD at <unknown>:0"]; } subgraph cluster2468 { label="mapPartitions"; 1111 [labelType="html" label="MapPartitionsRDD [1111] toJavaRDD at <unknown>:0"]; } } 1092->1093; 1093->1094; 1094->1095; 1095->1096; 1096->1103; 1103->1104; 1104->1105; 1105->1106; 1106->1107; 1107->1108; 1108->1109; 1109->1110; 1110->1111; 1111->1112; }

Event Timeline

Enable zooming