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

digraph G { subgraph clusterstage_1542 { label="Stage 1542"; 16195 [labelType="html" label="SQLExecutionRDD [16195] run at <unknown>:0"]; 16203 [labelType="html" label="SQLExecutionRDD [16203] toJavaRDD at <unknown>:0"]; 16205 [labelType="html" label="PythonRDD [16205] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster36242 { label="MicroBatchScan"; 16191 [labelType="html" label="DataSourceRDD [16191] run at <unknown>:0"]; 16192 [labelType="html" label="MapPartitionsRDD [16192] run at <unknown>:0"]; } subgraph cluster36241 { label="Project"; 16193 [labelType="html" label="MapPartitionsRDD [16193] run at <unknown>:0"]; } subgraph cluster36237 { label="WholeStageCodegen (1)"; 16194 [labelType="html" label="MapPartitionsRDD [16194] run at <unknown>:0"]; } subgraph cluster36251 { label="WholeStageCodegen (1)"; 16196 [labelType="html" label="MapPartitionsRDD [16196] toJavaRDD at <unknown>:0"]; } subgraph cluster36250 { label="Filter"; 16197 [labelType="html" label="MapPartitionsRDD [16197] toJavaRDD at <unknown>:0"]; } subgraph cluster36249 { label="Project"; 16198 [labelType="html" label="MapPartitionsRDD [16198] toJavaRDD at <unknown>:0"]; } subgraph cluster36246 { label="WholeStageCodegen (2)"; 16199 [labelType="html" label="MapPartitionsRDD [16199] toJavaRDD at <unknown>:0"]; } subgraph cluster36245 { label="Project"; 16200 [labelType="html" label="MapPartitionsRDD [16200] toJavaRDD at <unknown>:0"]; } subgraph cluster36244 { label="DeserializeToObject"; 16201 [labelType="html" label="MapPartitionsRDD [16201] toJavaRDD at <unknown>:0"]; } subgraph cluster36243 { label="MapPartitions"; 16202 [labelType="html" label="MapPartitionsRDD [16202] toJavaRDD at <unknown>:0"]; } subgraph cluster36253 { label="mapPartitions"; 16204 [labelType="html" label="MapPartitionsRDD [16204] toJavaRDD at <unknown>:0"]; } } 16191->16192; 16192->16193; 16193->16194; 16194->16195; 16195->16196; 16196->16197; 16197->16198; 16198->16199; 16199->16200; 16200->16201; 16201->16202; 16202->16203; 16203->16204; 16204->16205; }

Event Timeline

Enable zooming