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

digraph G { subgraph clusterstage_1834 { label="Stage 1834"; 19261 [labelType="html" label="SQLExecutionRDD [19261] run at <unknown>:0"]; 19269 [labelType="html" label="SQLExecutionRDD [19269] toJavaRDD at <unknown>:0"]; 19271 [labelType="html" label="PythonRDD [19271] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster43104 { label="MicroBatchScan"; 19257 [labelType="html" label="DataSourceRDD [19257] run at <unknown>:0"]; 19258 [labelType="html" label="MapPartitionsRDD [19258] run at <unknown>:0"]; } subgraph cluster43103 { label="Project"; 19259 [labelType="html" label="MapPartitionsRDD [19259] run at <unknown>:0"]; } subgraph cluster43099 { label="WholeStageCodegen (1)"; 19260 [labelType="html" label="MapPartitionsRDD [19260] run at <unknown>:0"]; } subgraph cluster43113 { label="WholeStageCodegen (1)"; 19262 [labelType="html" label="MapPartitionsRDD [19262] toJavaRDD at <unknown>:0"]; } subgraph cluster43112 { label="Filter"; 19263 [labelType="html" label="MapPartitionsRDD [19263] toJavaRDD at <unknown>:0"]; } subgraph cluster43111 { label="Project"; 19264 [labelType="html" label="MapPartitionsRDD [19264] toJavaRDD at <unknown>:0"]; } subgraph cluster43108 { label="WholeStageCodegen (2)"; 19265 [labelType="html" label="MapPartitionsRDD [19265] toJavaRDD at <unknown>:0"]; } subgraph cluster43107 { label="Project"; 19266 [labelType="html" label="MapPartitionsRDD [19266] toJavaRDD at <unknown>:0"]; } subgraph cluster43106 { label="DeserializeToObject"; 19267 [labelType="html" label="MapPartitionsRDD [19267] toJavaRDD at <unknown>:0"]; } subgraph cluster43105 { label="MapPartitions"; 19268 [labelType="html" label="MapPartitionsRDD [19268] toJavaRDD at <unknown>:0"]; } subgraph cluster43115 { label="mapPartitions"; 19270 [labelType="html" label="MapPartitionsRDD [19270] toJavaRDD at <unknown>:0"]; } } 19257->19258; 19258->19259; 19259->19260; 19260->19261; 19261->19262; 19262->19263; 19263->19264; 19264->19265; 19265->19266; 19266->19267; 19267->19268; 19268->19269; 19269->19270; 19270->19271; }

Event Timeline

Enable zooming