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

digraph G { subgraph clusterstage_1536 { label="Stage 1536"; 16132 [labelType="html" label="SQLExecutionRDD [16132] run at <unknown>:0"]; 16140 [labelType="html" label="SQLExecutionRDD [16140] toJavaRDD at <unknown>:0"]; 16142 [labelType="html" label="PythonRDD [16142] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster36101 { label="MicroBatchScan"; 16128 [labelType="html" label="DataSourceRDD [16128] run at <unknown>:0"]; 16129 [labelType="html" label="MapPartitionsRDD [16129] run at <unknown>:0"]; } subgraph cluster36100 { label="Project"; 16130 [labelType="html" label="MapPartitionsRDD [16130] run at <unknown>:0"]; } subgraph cluster36096 { label="WholeStageCodegen (1)"; 16131 [labelType="html" label="MapPartitionsRDD [16131] run at <unknown>:0"]; } subgraph cluster36110 { label="WholeStageCodegen (1)"; 16133 [labelType="html" label="MapPartitionsRDD [16133] toJavaRDD at <unknown>:0"]; } subgraph cluster36109 { label="Filter"; 16134 [labelType="html" label="MapPartitionsRDD [16134] toJavaRDD at <unknown>:0"]; } subgraph cluster36108 { label="Project"; 16135 [labelType="html" label="MapPartitionsRDD [16135] toJavaRDD at <unknown>:0"]; } subgraph cluster36105 { label="WholeStageCodegen (2)"; 16136 [labelType="html" label="MapPartitionsRDD [16136] toJavaRDD at <unknown>:0"]; } subgraph cluster36104 { label="Project"; 16137 [labelType="html" label="MapPartitionsRDD [16137] toJavaRDD at <unknown>:0"]; } subgraph cluster36103 { label="DeserializeToObject"; 16138 [labelType="html" label="MapPartitionsRDD [16138] toJavaRDD at <unknown>:0"]; } subgraph cluster36102 { label="MapPartitions"; 16139 [labelType="html" label="MapPartitionsRDD [16139] toJavaRDD at <unknown>:0"]; } subgraph cluster36112 { label="mapPartitions"; 16141 [labelType="html" label="MapPartitionsRDD [16141] toJavaRDD at <unknown>:0"]; } } 16128->16129; 16129->16130; 16130->16131; 16131->16132; 16132->16133; 16133->16134; 16134->16135; 16135->16136; 16136->16137; 16137->16138; 16138->16139; 16139->16140; 16140->16141; 16141->16142; }

Event Timeline

Enable zooming