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

digraph G { subgraph clusterstage_1363 { label="Stage 1363"; 14327 [labelType="html" label="SQLExecutionRDD [14327] run at <unknown>:0"]; 14335 [labelType="html" label="SQLExecutionRDD [14335] toJavaRDD at <unknown>:0"]; 14337 [labelType="html" label="PythonRDD [14337] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster32055 { label="MicroBatchScan"; 14323 [labelType="html" label="DataSourceRDD [14323] run at <unknown>:0"]; 14324 [labelType="html" label="MapPartitionsRDD [14324] run at <unknown>:0"]; } subgraph cluster32054 { label="Project"; 14325 [labelType="html" label="MapPartitionsRDD [14325] run at <unknown>:0"]; } subgraph cluster32050 { label="WholeStageCodegen (1)"; 14326 [labelType="html" label="MapPartitionsRDD [14326] run at <unknown>:0"]; } subgraph cluster32064 { label="WholeStageCodegen (1)"; 14328 [labelType="html" label="MapPartitionsRDD [14328] toJavaRDD at <unknown>:0"]; } subgraph cluster32063 { label="Filter"; 14329 [labelType="html" label="MapPartitionsRDD [14329] toJavaRDD at <unknown>:0"]; } subgraph cluster32062 { label="Project"; 14330 [labelType="html" label="MapPartitionsRDD [14330] toJavaRDD at <unknown>:0"]; } subgraph cluster32059 { label="WholeStageCodegen (2)"; 14331 [labelType="html" label="MapPartitionsRDD [14331] toJavaRDD at <unknown>:0"]; } subgraph cluster32058 { label="Project"; 14332 [labelType="html" label="MapPartitionsRDD [14332] toJavaRDD at <unknown>:0"]; } subgraph cluster32057 { label="DeserializeToObject"; 14333 [labelType="html" label="MapPartitionsRDD [14333] toJavaRDD at <unknown>:0"]; } subgraph cluster32056 { label="MapPartitions"; 14334 [labelType="html" label="MapPartitionsRDD [14334] toJavaRDD at <unknown>:0"]; } subgraph cluster32066 { label="mapPartitions"; 14336 [labelType="html" label="MapPartitionsRDD [14336] toJavaRDD at <unknown>:0"]; } } 14323->14324; 14324->14325; 14325->14326; 14326->14327; 14327->14328; 14328->14329; 14329->14330; 14330->14331; 14331->14332; 14332->14333; 14333->14334; 14334->14335; 14335->14336; 14336->14337; }

Event Timeline

Enable zooming